You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ja...@apache.org on 2018/11/27 09:48:42 UTC
[35/50] samza git commit: Cleanup the EventHubs connector section.
Use System/Stream Descriptors
Cleanup the EventHubs connector section. Use System/Stream Descriptors
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/d315cae6
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/d315cae6
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/d315cae6
Branch: refs/heads/master
Commit: d315cae63bf514a15152c23b8b7e8fde786f8bc5
Parents: 3273e96 affc312
Author: Jagadish <jv...@linkedin.com>
Authored: Mon Oct 29 16:29:39 2018 -0700
Committer: Jagadish <jv...@linkedin.com>
Committed: Mon Oct 29 16:29:39 2018 -0700
----------------------------------------------------------------------
docs/learn/documentation/versioned/connectors/kafka.md | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/d315cae6/docs/learn/documentation/versioned/connectors/kafka.md
----------------------------------------------------------------------
diff --cc docs/learn/documentation/versioned/connectors/kafka.md
index 5b15b91,447bfdc..b71c736
--- a/docs/learn/documentation/versioned/connectors/kafka.md
+++ b/docs/learn/documentation/versioned/connectors/kafka.md
@@@ -136,14 -137,14 +136,14 @@@ In this section, we walk through a comp
{% endhighlight %}
- -Lines 1-3 create a KafkaSystemDescriptor defining the coordinates of our Kafka cluster
+ - Lines 1-3 create a KafkaSystemDescriptor defining the coordinates of our Kafka cluster
- -Lines 4-6 define a KafkaInputDescriptor for our input topic - `page-views`
+ - Lines 4-6 defines a KafkaInputDescriptor for our input topic - `page-views`
- -Lines 7-9 define a KafkaOutputDescriptor for our output topic - `filtered-page-views`
+ - Lines 7-9 defines a KafkaOutputDescriptor for our output topic - `filtered-page-views`
- -Line 9 creates a MessageStream for the input topic so that you can chain operations on it later
+ - Line 9 creates a MessageStream for the input topic so that you can chain operations on it later
- -Line 10 creates an OuputStream for the output topic
+ - Line 10 creates an OuputStream for the output topic
- -Lines 11\-13 define a simple pipeline that reads from the input stream and writes filtered results to the output stream
-- Lines 11-13 define a simple pipeline that reads from the input stream and writes filtered results to the output stream
++- Lines 11-13 define a simple pipeline that reads from the input stream and writes filtered results to the output stream