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 <jvenkatra...@linkedin.com> Authored: Mon Oct 29 16:29:39 2018 -0700 Committer: Jagadish <jvenkatra...@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