From 4df68580e9ab9b3b2c95f0c177875ef81c72a3f1 Mon Sep 17 00:00:00 2001 From: Thomas Weise Date: Mon, 26 Jun 2017 22:23:02 -0400 Subject: [PATCH] documentation fixes --- docs/operators/kafkaInputOperator.md | 22 ++++++++++++++-------- examples/jdbc/pom.xml | 4 ++-- 2 files changed, 16 insertions(+), 10 deletions(-) diff --git a/docs/operators/kafkaInputOperator.md b/docs/operators/kafkaInputOperator.md index 2886b4b2d9..7d83f72351 100644 --- a/docs/operators/kafkaInputOperator.md +++ b/docs/operators/kafkaInputOperator.md @@ -398,33 +398,39 @@ public class ExampleKafkaApplication implements StreamingApplication } } ``` -Below is the configuration for “test” Kafka topic name and -“localhost:9092” is the Broker: +Below is the configuration for topic “test” and broker “localhost:9092”: ```xml - dt.operator.MessageReader.prop.topics + apex.operator.MessageReader.prop.topics test - dt.operator.KafkaInputOperator.prop.clusters + apex.operator.KafkaInputOperator.prop.clusters localhost:9092 ``` -By adding following lines to properties file, Kafka Input Operator supports multi-topic and multi-cluster: +Multiple topics can be specified as a comma-separated list; similarly, multiple clusters can be specified as a semicolon-separated list; for example: ```xml - dt.operator.MessageReader.prop.topics + apex.operator.MessageReader.prop.topics test1, test2 - dt.operator.KafkaInputOperator.prop.clusters + apex.operator.KafkaInputOperator.prop.clusters localhost:9092; localhost:9093; localhost:9094 ``` -For a full example application project, refer to https://github.com/DataTorrent/examples/tree/master/tutorials/kafka +A full example application project can be found [here](https://github.com/apache/apex-malhar/tree/master/examples/kafka). + +### Security + +Kafka from 0.9.x onwards supports [Authentication, Encryption and Authorization](https://kafka.apache.org/090/documentation.html#security_overview). + +See [here](http://apache-apex-users-list.78494.x6.nabble.com/kafka-td1089.html) for more information. + diff --git a/examples/jdbc/pom.xml b/examples/jdbc/pom.xml index b01028a669..79a36fa34e 100644 --- a/examples/jdbc/pom.xml +++ b/examples/jdbc/pom.xml @@ -23,11 +23,11 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> 4.0.0 - malhar-examples-JDBC + malhar-examples-jdbc jar Apache Apex Malhar JDBC Examples - Demostrates the JDBC Examples + Apache Apex Malhar JDBC Examples org.apache.apex