Ryan,

The correct consumer command in the latest doc (
http://kafka.apache.org/quickstart#quickstart_consume) is

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic 
test --from-beginning

You used the "--zookeeper" parameter which implies using the old consumer, 
in which case the correct port is 2181, as you figured out.
Using "--bootstrap-server" and port 9092 implies using the new (Java) 
consumer.

Regards,
--Vahid




From:   "paradixrain" <paradixr...@qq.com>
To:     "users" <users@kafka.apache.org>
Date:   12/07/2016 09:10 PM
Subject:        Q about doc of consumer



Dear kafka,
I think there is an error in the document, is that right?


Here's what I did:
Step 1:
 open a producer
./kafka-console-producer.sh --broker-list localhost:9092 --topic test

Step 2:
open a consumer
./kafka-console-consumer.sh --zookeeper localhost:9092 --topic test 
--from-beginning

Step 3:
I input something in producer

but got errors below in consumer:


Step 4:
I change the port in Step 2 from 9090 to 2181, and restarted consumer
after that I got what I want


------------------
YOUR FRIEND,
Ryan
 



Reply via email to