Spring 2 个不同的 kafka 集群设置的 Kafka 配置

Question

在我们的一项基于 spring-boot 的服务中，我们打算同时连接到 2 个不同的 kafka 集群。这些集群每个都有自己的一组 bootstrap-服务器、主题配置等。它们之间没有任何关系，就像 this question.

中的情况一样

我将从每个集群读取不同主题名称的不同类型的消息。可能有也可能没有多个生产者从该服务连接到两个集群，但我们肯定每个集群至少有一个消费者。

我想知道如何在 application.yml 中定义属性来满足此设置，这样我就可以使用 2 个不同的 KafkaProperties 对象来创建 4 个容器工厂（2 个消费者，2 个制作人）。我相信其余的应该非常简单，因为我需要使用相关工厂根据业务需求创建特定的 container/listener/kafkaTemplate。

Answer 1

你不能；您需要禁用 Boot 的自动配置并自行为每个集群配置基础结构 bean。

Boot的自动配置只支持一个集群。