如果第一个集群使用java出现故障，如何将消息推送到第二个kafka集群主题

【问题标题】：How to push message to second kafka cluster topic if first cluster goes down using java如果第一个集群使用java出现故障，如何将消息推送到第二个kafka集群主题
【发布时间】：2020-07-13 05:20:15
【问题描述】：

我有一个场景，我需要使用 java 将消息推送到 kafka 主题中......但条件是如果我的一个集群出现故障，则需要连接另一个 kafka 集群并推送消息。

【问题讨论】：

标签： java spring-boot apache-kafka spring-kafka kafka-producer-api

【解决方案1】：

您需要配置两个 DefaultKafkaProducerFactory bean 和两个 KafkaTemplates。

当您遇到异常时，故障转移到另一个模板。

【讨论】：

可能与 Ops 问题无关。总是在后台调度程序任务中检查集群并更新现有的工厂、模板和侦听器 bean 以使用健康的集群是否有意义？这样我们就不需要维护两个 bean。有可能吗？
它可能有效，但你必须停止监听容器，更改工厂的代理地址，调用生产者工厂的reset() 并重新启动容器；您不能使用默认工厂执行此操作，因为它们不提供更改配置属性的机制。