OrcHome OrcHome
OrcHome个人中心.

沉默行僧

已关注 关注

关注

暂无关注.....

粉丝

暂无粉丝.....


沉默行僧 回复 半兽人 KafkaConsumer 调用poll,进入死循环 中:
解决了,之前我用的ambari,有三个服务器,但是默认建了一个broker。刚才我增加到三个就ok了。非常感谢你的解答,困惑了一两天
1月前
半兽人 回复 沉默行僧 KafkaConsumer 调用poll,进入死循环 中:
http://orchome.com/454
用新消费者和生产者命令测试一下。还有消费者活跃列表,集群状态等
1月前
沉默行僧 回复 半兽人 KafkaConsumer 调用poll,进入死循环 中:
旧的正常,新的producer 也是正常的 就是consumer调用poll方法不正常,收不到数据。同时用新api的producer 加上旧api的ConsumerConnector也是可以正常运作的
1月前
半兽人 回复 沉默行僧 KafkaConsumer 调用poll,进入死循环 中:
新api正常吗?
1月前
沉默行僧 回复 半兽人 KafkaConsumer 调用poll,进入死循环 中:
我了解poll的功能,但是日志很明确的提示“The coordinator is not available.”coordinator 不可用,不知道为什么,其他方式都可以
1月前
发表了 KafkaConsumer 调用poll,进入死循环
1月前

沉默行僧 回复 半兽人 KafkaConsumer 调用poll,进入死循环 评论:
解决了,之前我用的ambari,有三个服务器,但是默认建了一个broker。刚才我增加到三个就ok了。非常感谢你的解答,困惑了一两天
1月前
半兽人 回复 沉默行僧 KafkaConsumer 调用poll,进入死循环 评论:
http://orchome.com/454
用新消费者和生产者命令测试一下。还有消费者活跃列表,集群状态等
1月前
沉默行僧 回复 半兽人 KafkaConsumer 调用poll,进入死循环 评论:
旧的正常,新的producer 也是正常的 就是consumer调用poll方法不正常,收不到数据。同时用新api的producer 加上旧api的ConsumerConnector也是可以正常运作的
1月前
半兽人 回复 沉默行僧 KafkaConsumer 调用poll,进入死循环 评论:
新api正常吗?
1月前
沉默行僧 回复 半兽人 KafkaConsumer 调用poll,进入死循环 评论:
我了解poll的功能,但是日志很明确的提示“The coordinator is not available.”coordinator 不可用,不知道为什么,其他方式都可以
1月前

沉默行僧 发表了 KafkaConsumer 调用poll,进入死循环
1月前