我使用以下命令创建了新的主题'rahul‘:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic rahul
Created topic "rahul".
我还重新检查了以下主题
bin/kafka-topics.sh --list --zookeeper localhost:2181
__consumer_offsets rahhy rahul`
现在启动生产者:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic rahul
hey
嗨,你好
但是,到了消费者展示消息的时候:什么都没有
发布于 2018-06-09 23:25:39
从Kafka 0.9开始,您将不再使用Zookeeper进行消费或生产
试试kafka-console-consumer --topic rahul --bootstrap-server localhost:9092
您还可以通过其他方式检查发送到Kafka的消息-通过检查主题分区的偏移量是否更改了using GetOffsetShell
https://stackoverflow.com/questions/50774212
复制相似问题