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是否被覆盖,或被占用
相关文章推荐
- apache kafka系列之kafka.common.ConsumerRebalanceFailedException异常解决办法
- kafka.common.ConsumerRebalanceFailedException异常解决
- apache kafka系列之kafka.common.ConsumerRebalanceFailedException异常解决办法
- kafka.common.ConsumerRebalanceFailedException-org.I0Itec.zkclient.exception.ZkNoNodeException
- apache kafka系列之kafka.common.ConsumerRebalanceFailedException异常解决办法
- apache kafka系列之kafka.common.ConsumerRebalanceFailedException异常解决办法
- kafka.common.ConsumerRebalanceFailedException :log-push-record-consumer-group_mobile-pushremind02.lf
- apache kafka系列之kafka.common.ConsumerRebalanceFailedException异常解决办法
- apache kafka系列之kafka.common.ConsumerRebalanceFailedException异常解决办法
- 【疑难杂症】记录 kafka.common.ConsumerRebalanceFailedException:异常
- kafka.common.ConsumerRebalanceFailedException
- 大数据_Kafka_kafka.common.ConsumerRebalanceFailedException异常解决办法
- kafka消费者报错:kafka.common.ConsumerRebalanceFailedException
- Caused by: kafka.common.OffsetOutOfRangeException
- elasticsearchException:Failed to load logging configuration Caused by: java.nio.file.NoSuchFileExcep
- Caused by: java.io.NotSerializableException: com.omhy.common.model.entity.XXX解决方法
- kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
- caused by android.system.errnoexception open failed eacces (permission denied)解决方案,安卓6.0(API23)权限问题
- caused by android.system.errnoexception open failed eacces (permission denied)解决方案,安卓6.0(API23)权限问题
- kafka 运行问题:kafka.common.KafkaException: Failed to acquire lock on file .lock 的处理