步骤： bin/zookeeper-server-start.sh config/zookeeper.properties bin/kafka-server-start.sh config/server.properties bin/kafka-console-producer.sh --broker-list localhost:9092 --topic sampleTopic
然后我在终端上输入一些信息。
当我在另一个终端执行以下操作时： bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sampleTopic --from-beginning 什么都没发生。没有消息没有错误。
Kafka版本：
编辑：
3条答案
按热度按时间ilmyapht1#
Kafka制作人不会立即发送消息。它创建并发送批处理。
确保关闭producer提示符，并尝试在producer之前启动consumer
甚至可以使用kafka的最新版本，或者选择apt repos for confluent platform，其中包括kafka、zookeeper和其他实用程序
js5cn81o2#
但在图像片段中，我可以看到您正在使用tessampletopic作为主题名，因此无法在控制台中打印任何内容。
请用sampletopic更正主题名称
b4lqfgs43#
请尝试使用以下命令：
我希望这个工作！！！