Splitting out Apex Malhar docs
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/e89f57e3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/e89f57e3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/e89f57e3 Branch: refs/heads/master Commit: e89f57e3773167d5cbff298e6f4e07ec5c692e9d Parents: 69bf67b Author: sashadt <[email protected]> Authored: Wed Mar 9 20:08:55 2016 -0800 Committer: Thomas Weise <[email protected]> Committed: Fri Mar 11 19:22:48 2016 -0800 ---------------------------------------------------------------------- docs/images/malhar-operators.png | Bin 0 -> 109734 bytes docs/operators/kafkaInputOperator.md | 34 +++--------------------------- 2 files changed, 3 insertions(+), 31 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e89f57e3/docs/images/malhar-operators.png ---------------------------------------------------------------------- diff --git a/docs/images/malhar-operators.png b/docs/images/malhar-operators.png new file mode 100644 index 0000000..ac09622 Binary files /dev/null and b/docs/images/malhar-operators.png differ http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e89f57e3/docs/operators/kafkaInputOperator.md ---------------------------------------------------------------------- diff --git a/docs/operators/kafkaInputOperator.md b/docs/operators/kafkaInputOperator.md index 793e255..1d2258e 100644 --- a/docs/operators/kafkaInputOperator.md +++ b/docs/operators/kafkaInputOperator.md @@ -266,45 +266,17 @@ public void populateDAG(DAG dag, Configuration entries) } } ``` -Below is the configuration for using the earliest offset, âtestâ as the topic name and -âlocalhost:2181â as the zookeeper forum: +Below is the configuration for âtestâ Kafka topic name and +âlocalhost:2181â is the zookeeper forum: ```xml <property> - <name>dt.operator.MessageReader.prop.initialOffset</name> - <value>earliest</value> -</property> - -<property> <name>dt.operator.MessageReader.prop.topic</name> <value>test</value> </property> <property> -<name>dt.operator.MessageReader.prop.zookeeper</nam> +<name>dt.operator.KafkaInputOperator.prop.zookeeper</nam> <value>localhost:2181</value> </property> ``` - -Please note that `MessageReader` is the string passed as the first argument to the -`addOperator()` call. The above stanza sets these parameters for this operator -regardless of the application it resides in; if you want to set them on a -per-application basis, you can use this instead (where `KafkaApp` is the name of -the application): - -```xml -<property> - <name>dt.application.KafkaApp.operator.MessageReader.prop.initialOffset</name> - <value>earliest</value> -</property> - -<property> - <name>dt.application.KafkaApp.operator.MessageReader.prop.topic</name> - <value>test-topic</value> -</property> - -<property> - <name>dt.application.KafkaApp.operator.MessageReader.prop.zookeeper</name> - <value>node21:2181</value> -</property> -```
