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

Question

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

标签： javaspring-bootapache-kafkaspring-kafkakafka-producer-api

Answer 1

您需要配置两个DefaultKafkaProducerFactorybean 和两个KafkaTemplates。

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