From 4563d69f50d3e3daab22aa8416c64bd302c325fa Mon Sep 17 00:00:00 2001 From: Manasa Date: Fri, 6 Dec 2019 11:21:12 -0800 Subject: [PATCH] DOCS: Update kafka consumer command to use bootstrap-server --- docs/startup/hello-samza/versioned/index.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/docs/startup/hello-samza/versioned/index.md b/docs/startup/hello-samza/versioned/index.md index 0b0ae9343c..325334ba27 100644 --- a/docs/startup/hello-samza/versioned/index.md +++ b/docs/startup/hello-samza/versioned/index.md @@ -75,7 +75,7 @@ deploy/samza/bin/run-app.sh --config-factory=org.apache.samza.config.factories.P The job will consume a feed of real-time edits from Wikipedia, and produce them to a Kafka topic called "wikipedia-raw". Give the job a minute to startup, and then tail the Kafka topic: {% highlight bash %} -deploy/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic wikipedia-raw +deploy/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wikipedia-raw {% endhighlight %} Pretty neat, right? Now, check out the YARN UI again ([http://localhost:8088](http://localhost:8088)). This time around, you'll see your Samza job is running! @@ -94,13 +94,13 @@ deploy/samza/bin/run-app.sh --config-factory=org.apache.samza.config.factories.P The first job (wikipedia-parser) parses the messages in wikipedia-raw, and extracts information about the size of the edit, who made the change, etc. You can take a look at its output with: {% highlight bash %} -deploy/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic wikipedia-edits +deploy/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wikipedia-edits {% endhighlight %} The last job (wikipedia-stats) reads messages from the wikipedia-edits topic, and calculates counts, every ten seconds, for all edits that were made during that window. It outputs these counts to the wikipedia-stats topic. {% highlight bash %} -deploy/kafka/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic wikipedia-stats +deploy/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic wikipedia-stats {% endhighlight %} The messages in the stats topic look like this: