kafka版本:kafka_2.12-2.0.0,部署三台 broker.id分别为0,1,3zookeeper 也部署了三台现将 其中broker.id=0的 kill,producer发送消息成功,costomer收不到消息
kafka0.9版本以后,consumer消费的offset默认保存到kafka系统topic中,所以你这种很可能是因为保存offset的topic只有一个副本。
非常感谢大神,按照https://www.orchome.com/454 增加__consumer_offsets 副本数解决了这个问题。
你的答案