您的位置:首页 > 大数据 > 人工智能

Kafka--Caused by: kafka.common.ConsumerRebalanceFailedException

2016-11-14 13:07 435 查看

说明

最近一个项目需要订阅kafka的某个topic的消息,当时运行很正常,过了几天发现项目启动时,报异常

Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name
'com.ximalaya.kafka.consumer.KafkaConsumerListenerContainer#0' defined in class path resource
[application-kafka-consumer-context.xml]: Invocation of init method failed; nested exception is
kafka.common.ConsumerRebalanceFailedException: test_nalideMacBook-Pro.local-1479090845106-
b4a88dcd can't rebalance after 4 retries
Caused by: kafka.common.ConsumerRebalanceFailedException: test_nalideMacBook-Pro.local-
1479090845106-b4a88dcd can't rebalance after 4 retries


解决方案

上网查询后,发现各种说法,大致如下:

* topic的分区新增了或者删除了

* zk的timeout设置太短

但都没有给出解决方案,就尝试修改配置参数,发现当我改变group.id后,项目正常启动

思考

问题解决了,但是问题为什么会发生呢?

* 的确是使用kafka命令给topic增加了分区

* 当前的group.id是否被覆盖,或被占用
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  kafka 异常
相关文章推荐