我们正在使用springboot应用程序来开发kafka流应用程序。直到现在，我们只使用单一经纪人，所以我们不会面临任何问题
但一周前，我们创建了集群模式，其中有3个zookeers和3个kafka代理，以提高可用性
我们将应用程序配置如下。

spring.kafka.bootstrap-servers=x.x.x.x:9093,x.x.x.x:9093,x.x.x.x:9093

一号领导二号领导三号领导
因此，我们正在测试服务器关闭行为，下面是测试结果
预期行为：它必须通过消费和生成数据而不受任何限制地连续运行
实际行为：如果我们关闭任何一台服务器，它将抛出异常，并且在应用程序停止一段时间后代理不可用
在分析原因时，我们发现消费主题具有leader-1，而数据生成主题具有leader-2，所以当我停止leader-1时，我们认为它将更改为下一个leader，但它不是？
这是默认行为还是我们做错了什么？
有人能给我建议如何克服这个问题吗？