You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/03/18 06:54:29 UTC
[11/18] incubator-apex-malhar git commit: Splitting out Apex Malhar
docs
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/devel-3
Commit: e89f57e3773167d5cbff298e6f4e07ec5c692e9d
Parents: 69bf67b
Author: sashadt <sa...@datatorrent.com>
Authored: Wed Mar 9 20:08:55 2016 -0800
Committer: Thomas Weise <th...@datatorrent.com>
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>
-```