我有3个经纪人的集群。我使用的主题配置了3个和4个分区的复制因子。我使用Kafka python API来设置生产者和消费者。
我的问题是，当我停止其中一个代理时，在某些情况下，我的消费者停止接收消息。

(When broker 1 is unavailable):
Topic: frogakas Partition: 0    Leader: 5   Replicas: 5,3,1 Isr: 5,3
    Topic: frogakas Partition: 1    Leader: 3   Replicas: 3,1,5 Isr: 3,5
    Topic: frogakas Partition: 2    Leader: 5   Replicas: 1,5,3 Isr: 5,3
    Topic: frogakas Partition: 3    Leader: 5   Replicas: 5,1,3 Isr: 5,3

问题是，当我关闭任何一家经纪人时，一些消费者群体就会消失。我的所有消费者共享相同的组ID，因此，他们停止工作，因为他们的组不在组列表中。
当所有代理都可用时，这些是组：

root@m3-virtual-machine:/opt/kafka/bin# ./kafka-consumer-groups.sh  --list --bootstrap-server localhost:9092
test_group_kas
test_group_1
test_group_2
test_group

当代理1不可用时，仅显示test_group_2：

root@m3-virtual-machine:/opt/kafka/bin# ./kafka-consumer-groups.sh  --list --bootstrap-server localhost:9092
test_group_2

此时，如果我启动一个groupId为test_group_2的消费者，消息将被正确接收。
我想知道当经纪人福尔斯时，是否有任何方法可以避免服务中断。