kafka集群部署三台服务器,kill其中一台,consumer收不到消息

八面佛 发表于: 2018-09-07   最后更新时间: 2018-09-07 11:21:46   4,746 游览

kafka版本:kafka_2.12-2.0.0,部署三台 broker.id分别为0,1,3
zookeeper 也部署了三台
现将 其中broker.id=0的 kill,producer发送消息成功,costomer收不到消息

screenshot

screenshot

发表于 2018-09-07
你看,之前有人遇到了,原因也在这,查看的是consumer_offsets这个主题。

kafka0.9版本以后,consumer消费的offset默认保存到kafka系统topic中,所以你这种很可能是因为保存offset的topic只有一个副本。
你可以通过命令查看topic有没有副本,命令如下:
bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic consumer_offsets

这个是存储offset的主题,如果副本只有1个,那么就会导致集群挂掉一个,你消费者再也不消费的情况。把该主题增加副本就行了。
你的答案

查看kafka相关的其他问题或提一个您自己的问题