两种不同Kafka群集设置的Spring Kafka配置
在我们的一个基于spring boot的服务中，我们打算同时连接到两个不同的kafka集群。这些集群都有自己的引导服务器集、主题配置等。它们之间没有任何关联，就像这个问题中的情况一样。
我将有不同类型的消息从不同主题名称的每个集群中读取。可能有或可能没有多个生产者通过此服务连接到两个集群，但我们肯定每个集群至少有一个消费者。
我想知道如何在application.yml中定义属性以满足此设置，以便我可以使用2个不同的KafkaProperties对象来创建4个容器工厂（2个消费者，2个生产者）。其余的，我相信，应该很简单，因为我需要根据业务要求使用相关工厂来创建特定的容器/侦听器/kafkaTemboard。
共有1个答案
你不能；您需要禁用Boot的自动配置，并自己为每个集群配置基础结构bean。
Boot的自动配置仅支持一个群集。
-
我已经在集群中配置了3个kafka，我正在尝试与sping-kafka一起使用。 但是在我杀死kafka领导者后，我无法发送其他消息到队列。 我将Spring.kafka.bootstrap-servers属性设置为：“kafka-1：9092;kafka-2：9093，kafka-3：9094”以及我的主机文件中的所有名称。 Kafka0.10版 有人知道如何正确配置？ 编辑 我测试过一个东西，
-
我想建立一个多kafka集群，大约有3个zookeeper实例，每个集群中有3个kafka代理，每个kafka经纪人大约有5个主题和5个分区。有什么设置指南可以参考吗？ PS:我可以找到带有多个Kafka代理的单个zookeeper实例的信息，但不能找到带有多个zookeeper实例的设置。
-
我有两个Kafka集群说A和B，B是A的复制品。仅当 A 关闭且相反，我才希望使用来自集群 B 的消息。然而，使用来自两个集群的消息会导致重复的消息。那么，有什么办法可以将我的 kafka 使用者配置为仅从一个集群接收消息。 谢谢-
-
我需要在不同的机器上配置一个Kafka集群，但它不起作用，当我启动生产者和消费者时，将显示以下错误： 你能帮帮我吗。
-
我有一个用例，我想建立一个Kafka集群，最初我有1个Kafka Broker(A)和1个Zookeeper节点。以下是我的疑问: > 在向集群添加新的Kafka Broker（B）时。代理A上存在的所有数据都会自动分发吗？如果不是，我需要做的是分发数据。 不，让我们假设情况以某种方式解决了！我的数据分布在两个代理上。现在由于一些维护问题，我想关闭服务器B。 如何将经纪商B的数据传输到已经存在的经
-
我有两台linux机器，都有不同的配置 机器1：16 GB RAM、4个虚拟内核和40 GB HDD（主从机） 我想运行我的spark应用程序，并尽可能多地利用虚拟内核和内存，但我无法确定是什么设置。 我的spark代码类似于： 到目前为止，我尝试了以下几种： 任何帮助都将不胜感激。