kafka消费报错coordinator unavailable.Rediscovery will be attempt redisCovery
kafka消费报错coordinator unavailable.Rediscovery will be attempt redisCovery
·
出现这个情况就是coordinate压力太大,_consumer_offset元主题中的历史消息分配不均衡,因为这个元主题的clean,policy不是正常的delete,所以会一直积累,并且单节点就很容易出现这个问题
解决办法:删除_consumer_offset历史文件,_consumer_offset历史文件是在log文件中的,我在kafka的config中的server.properties文件中设置的将log打印在指定目录下,
所以我的_consumer_offset历史文件在/java/kafka/logs文件中
也就是这里,
将_consumer_offset历史文件进行删除
这样就可以了
更多推荐
已为社区贡献1条内容
所有评论(0)