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