出现这个情况就是coordinate压力太大,_consumer_offset元主题中的历史消息分配不均衡,因为这个元主题的clean,policy不是正常的delete,所以会一直积累,并且单节点就很容易出现这个问题
    解决办法:删除_consumer_offset历史文件,_consumer_offset历史文件是在log文件中的,我在kafka的config中的server.properties文件中设置的将log打印在指定目录下,
在这里插入图片描述
所以我的_consumer_offset历史文件在/java/kafka/logs文件中
在这里插入图片描述

也就是这里,
在这里插入图片描述
将_consumer_offset历史文件进行删除
在这里插入图片描述
这样就可以了

Logo

大数据从业者之家,一起探索大数据的无限可能!

更多推荐