沉默行僧

0 声望

这家伙太懒，什么都没留下

个人动态

沉默行僧回复半兽人在 KafkaConsumer 调用poll，进入死循环中：
解决了，之前我用的ambari，有三个服务器，但是默认建了一个broker。刚才我增加到三个就ok了。非常感谢你的解答，困惑了一两天

6年前
半兽人回复沉默行僧在 KafkaConsumer 调用poll，进入死循环中：
https://www.orchome.com/454
用新消费者和生产者命令测试一下。还有消费者活跃列表，集群状态等

6年前
沉默行僧回复半兽人在 KafkaConsumer 调用poll，进入死循环中：
旧的正常，新的producer 也是正常的就是consumer调用poll方法不正常，收不到数据。同时用新api的producer 加上旧api的ConsumerConnector也是可以正常运作的

6年前
半兽人回复沉默行僧在 KafkaConsumer 调用poll，进入死循环中：
新api正常吗？

6年前
沉默行僧回复半兽人在 KafkaConsumer 调用poll，进入死循环中：
我了解poll的功能，但是日志很明确的提示“The coordinator is not available.”coordinator 不可用，不知道为什么，其他方式都可以

6年前
发表了 KafkaConsumer 调用poll，进入死循环

6年前