运维开发网

kafka消费者报错:kafka.common.ConsumerRebalanceFailedException

运维开发网 https://www.qedev.com 2020-04-07 10:45 出处:网络 作者:运维开发网整理
使用hignlevel consumer api 消费kafka消息,报错如下: 可能原因1: 1.每个consumer的client.id启动时,配置不同。 2.不配置client.id,有kafka server生成。 3.配置zk问题(kafka的consumer配置) zookeeper.session.timeout.ms=5000 zookeeper.connection.timeou

kafka消费者报错:kafka.common.ConsumerRebalanceFailedException

使用hignlevel consumer api 消费kafka消息,报错如下:

可能原因1:

1.每个consumer的client.id启动时,配置不同。

2.不配置client.id,有kafka server生成。

3.配置zk问题(kafka的consumer配置)

zookeeper.session.timeout.ms=5000

zookeeper.connection.timeout.ms=10000

zookeeper.sync.time.ms=2000

最坑的原因2:

少包。缺少相关的jar包,可以尝试把kafka libs文件夹下的所有包导入,尝试看是否解决。

原因3:有多个消费者使用同一个topic

同一时间只能有一个消费者使用同一个topic进行消费。

问题2:kafka不消费消息

一台电脑上可以消费,使用同样的配置,另外一台电脑上面不行,可能是groupId的问题,修改groupId.

0

精彩评论

暂无评论...
验证码 换一张
取 消