Quarkus/Smallrye Reactive Messaging/Kafka多集群连接
目前我有一个Quarkus应用程序，它从一个Kafka话题消费，并在另一个Kafka话题上生产。它使用SmallRye反应消息传递。效果很好。由于外部更改，要在其上生成的主题和要从其消费的主题将在不同集群上的Kafka服务器上（并且不应该/不能组合在一个集群中）。
kafka:
bootstrap:
servers: localhost:9092
在这里添加一个服务器并没有帮助，它会尝试将数据传播到代理上，这不是我的本意。
是否可能连接到多个集群（可能每个主题设置一个服务器）？在网上找不到任何东西，不是在Quarkus的文件里，也不是在SmallRye的文件里。
共有1个答案
这不是很清楚，但在文档中有解释，例如在kafka入站文档中，您可以使用kafka.
)或每个通道配置代理。
您可以向每个频道传递所有支持的Kafka属性：
mp.messaging.incoming.chanel1.bootstrap.servers=kafka1:9092
mp.messaging.incoming.chanel2.bootstrap.servers=kafka2:9092
-
我有一个Spring启动应用程序，它使用来自 Kafka 集群中某个主题（例如 topic1）的消息。这就是我的代码目前的样子。 现在我想从另一个Kafka集群中的不同主题开始消费。一种方法是为此创建另一个bean。但是有更好的方法吗？
-
我想建立一个多kafka集群，大约有3个zookeeper实例，每个集群中有3个kafka代理，每个kafka经纪人大约有5个主题和5个分区。有什么设置指南可以参考吗？ PS:我可以找到带有多个Kafka代理的单个zookeeper实例的信息，但不能找到带有多个zookeeper实例的设置。
-
我按照以下说明设置了一个多节点kafka集群。现在，如何连接到动物园管理员？在JAVA中，只连接一个来自生产者/消费者端的动物园管理员可以吗？或者有办法连接所有的动物园管理员节点吗？ 设置多节点阿帕奇动物园守护者集群 在集群的每个节点上，将以下行添加到文件kafka/config/zookeeper.properties中 在群集的每个节点上，在由 dataDir 属性表示的文件夹中创建一个名为
-
我尝试了kafka-console-consumer.sh和kafka-console-producer.sh,它工作得很好。我能够看到生产者在消费者中发送的消息 1）我已经下载了s3连接器(https://docs.confluent.io/current/connect/kafka-connect-S3/index.html) 2）将文件解压缩到/home/ec2-user/plugins/
-
我已经在集群中配置了3个kafka，我正在尝试与sping-kafka一起使用。 但是在我杀死kafka领导者后，我无法发送其他消息到队列。 我将Spring.kafka.bootstrap-servers属性设置为：“kafka-1：9092;kafka-2：9093，kafka-3：9094”以及我的主机文件中的所有名称。 Kafka0.10版 有人知道如何正确配置？ 编辑 我测试过一个东西，
-
想要从使用的Spring启动应用程序的不同集群上创建同质。 即想要为已经定义的类创建一个 Kafka Consumer 对象，该对象侦听动态定义的多个集群。 例如：假设一个Spring启动应用程序S，其中包含kafkaconsumer的