具有新API的Kafka消费者不工作

Question

我发现Kafka有一些非常奇怪的地方。

我有一个制片人，有三个经纪人：

bin/kafka-console-producer.sh --broker-list localhost:9093, localhost:9094, localhost:9095 --topic topic

然后，我尝试使用新的API运行消费者:

bin/kafka-console-consumer.sh --bootstrap-server localhost:9093,localhost:9094,localhost:9095 --topic topic --from-beginning

我什么都没有！但是如果我使用旧的API：

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic topic

我收到我的留言了！

我怎么了？

PS:我用的是Kafka10

Answer 1

多亏了这篇类似的文章，我最终解决了我的问题：Kafka引导服务器与Kafka控制台消费者中的动物园管理员

我相信是我的错误配置导致了动物园管理员和Kafka的问题。

解决方案:

首先确保在server中启用主题删除。经纪人的属性文件：

# Switch to enable topic deletion or not, default value is false
delete.topic.enable=true

然后删除主题：

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic myTopic

删除代理的所有/tmp/log.dir目录。

编辑：我又遇到了这个问题，我还必须删除/tmp/zookeeper/version-2/中zookeoper的日志文件。

最后删除动物园管理员中 /经纪人/主题中的主题，如下所示：

$ kafka/bin/zookeeper-shell.sh localhost:2181
Connecting to localhost:2181
Welcome to ZooKeeper!
JLine support is disabled

rmr /broker/topics/mytopic

重启你的经纪人，再次创造你的话题。