0

我们有一个处理消息生产和消费的服务器。我们有 4 台笔记本电脑,所有带有 confluent 的 Mac 都运行相同的命令行......

./kafka-avro-console-consumer --from-beginning --bootstrap-server 0.0.0.0:9092,0.0.0.0:9092 --topic topicName --property schema.registry.url= http://0.0.0.0 :8081

4 台笔记本电脑中有 3 台在使用消息时没有问题,但第四台不会。我已经确认我的笔记本电脑对 IP 地址具有相同的访问权限,我可以通过转到地址 /subjects 来查看架构注册表中的主题,并且我在控制台和日志中都没有收到任何错误。

我完全不知道还要检查什么。有没有其他人遇到过这种情况并可能找到解决方案?

4

1 回答 1

0

两个(或更多)唯一的控制台消费者应用程序获得与另一个完全相同的“随机”消费者组 ID 的可能性很小,因此您只会在分配有数据的主题分区的实例上看到消息。

一种解决方案是将唯一的组作为消费者属性传递给每台机器,否则尝试在机器上重新启动命令几次,而不是获取数据以随机化新的组 id。

我假设您实际上并没有在命令中使用 0.0.0.0

于 2018-10-01T02:24:50.323 回答