如果第一个代理关闭，则Kafka消费者无法消费

Question

./kafka-topics.sh --create    --zookeeper localhost:2181  --replication-factor 3     --partitions 13    --topic demo

./kafka-console-producer.sh --topic  demo  --broker-list localhost:9094,localhost:9093,localhost:9092

./kafka-console-consumer.sh --group test --bootstrap-server localhost:9094,localhost:9093,localhost:9092  --topic demo

当所有的经纪人都起来的时候，一切都是好的。但是，如果我先杀死（按开始顺序），代理消息会被发送到代理，但使用者不能接收到任何消息，消息不会丢失。启动该代理后，使用者立即接收消息。

关闭broker实例后的使用者日志：

再次启动丢失的代理后的使用者日志：

谢谢

Answer 1

尝试检查server-*.properties文件中的“offsets.topic.replication.factor”

例如：

############################# Internal Topic Settings       
# The replication factor for the group metadata internal topics    
# For anything other than development testing, a value greater than 1 is  recommended for to ensure availability such as 3.
offsets.topic.replication.factor=3

http://kafka.apache.org/documentation/#brokerconfigs