Repository: apex-malhar Updated Branches: refs/heads/master df13332c1 -> 4df68580e
documentation fixes Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/4df68580 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/4df68580 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/4df68580 Branch: refs/heads/master Commit: 4df68580e9ab9b3b2c95f0c177875ef81c72a3f1 Parents: df13332 Author: Thomas Weise <[email protected]> Authored: Mon Jun 26 22:23:02 2017 -0400 Committer: Thomas Weise <[email protected]> Committed: Mon Jun 26 22:51:51 2017 -0400 ---------------------------------------------------------------------- docs/operators/kafkaInputOperator.md | 22 ++++++++++++++-------- examples/jdbc/pom.xml | 4 ++-- 2 files changed, 16 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/4df68580/docs/operators/kafkaInputOperator.md ---------------------------------------------------------------------- diff --git a/docs/operators/kafkaInputOperator.md b/docs/operators/kafkaInputOperator.md index 2886b4b..7d83f72 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 <property> - <name>dt.operator.MessageReader.prop.topics</name> + <name>apex.operator.MessageReader.prop.topics</name> <value>test</value> </property> <property> - <name>dt.operator.KafkaInputOperator.prop.clusters</nam> + <name>apex.operator.KafkaInputOperator.prop.clusters</name> <value>localhost:9092</value> </property> ``` -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 <property> - <name>dt.operator.MessageReader.prop.topics</name> + <name>apex.operator.MessageReader.prop.topics</name> <value>test1, test2</value> </property> <property> - <name>dt.operator.KafkaInputOperator.prop.clusters</nam> + <name>apex.operator.KafkaInputOperator.prop.clusters</nam> <value>localhost:9092; localhost:9093; localhost:9094</value> </property> ``` -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. + http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/4df68580/examples/jdbc/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jdbc/pom.xml b/examples/jdbc/pom.xml index b01028a..79a36fa 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";> <modelVersion>4.0.0</modelVersion> - <artifactId>malhar-examples-JDBC</artifactId> + <artifactId>malhar-examples-jdbc</artifactId> <packaging>jar</packaging> <name>Apache Apex Malhar JDBC Examples</name> - <description>Demostrates the JDBC Examples</description> + <description>Apache Apex Malhar JDBC Examples</description> <parent> <groupId>org.apache.apex</groupId>
