apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [5/6] incubator-apex-malhar git commit: Splitting out Apex Malhar docs
Date Fri, 11 Mar 2016 20:54:44 GMT
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/608207b5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/608207b5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/608207b5

Branch: refs/heads/master
Commit: 608207b540226cf1eb218a069d974cabb22bf3a4
Parents: 5353fdd
Author: sashadt <sasha@datatorrent.com>
Authored: Wed Mar 9 20:08:55 2016 -0800
Committer: Thomas Weise <thomas@datatorrent.com>
Committed: Fri Mar 11 12:43:08 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/608207b5/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/608207b5/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>
-```


Mime
View raw message