问kafka消费者没有显示消息吗？
EN

Stack Overflow用户

提问于 2018-06-09 20:17:51

回答 1查看 2.8K关注 0票数 0

我使用以下命令创建了新的主题'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

票数 3

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/50774212

复制

相似问题

问kafka消费者没有显示消息吗？EN