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

八面佛 发表于: 2018-09-07   最后更新时间: 2018-09-07  

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

screenshot

screenshot



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: 到头了!
下一条: 已经是最后了!

  • 你看,之前有人遇到了,原因也在这,查看的是consumer_offsets这个主题。

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

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