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
