apache-kafka - 当其中一个代理发生故障而其他代理正在运行时，Kafka Stream 应用程序会发生故障

Question

我们有一个使用 Spring Cloud Stream 的 Kafka Stream 应用程序，使用 AWS MSK 连接到 3 个复制因子为 3 的代理。

现在每个月都会进行一次定期修补，每次只有一个经纪人出现故障。但是，即使一个代理关闭而其他 2 个代理异常启动，Kafka 流应用程序也会关闭（SHUTDOWN 状态）

org.apache.kafka.clients.NetworkClient：[AdminClient clientId=blabla] 无法建立到节点 1 的连接。经纪人可能不可用。

有人可以指导我确保即使其他 2 个代理在此间隔期间启动，Kafka 流也不会关闭。

标签： apache-kafkaapache-kafka-streamsspring-cloud-streamspring-cloud-stream-binder-kafka