Quarkus/SmallRye Reactive Messaging/Kafka 连接多个集群

Question

目前我有一个 Quarkus 应用程序，它从 Kafka 主题消费并在另一个 Kafka 主题上生成。它使用 SmallRye 反应式消息传递。效果很好。由于外部更改，要生成的主题和要使用的主题将位于不同集群上的 Kafka 服务器上（并且不应该/不能组合在一个集群中）。

在应用程序配置（yaml）中我们设置Kafka服务器（broker）：

kafka:
  bootstrap:
    servers: localhost:9092

在这里添加服务器没有帮助，然后它尝试将数据传播到代理上，这不是我的意图。

是否可以连接到多个集群（也许为每个主题设置一个服务器）？在互联网上找不到任何相关内容，无论是Quarkus 文档还是SmallRye 文档。

Answer 1

这不是很清楚，但它在文档中进行了解释，例如在kafka 入站文档中，据说您可以全局（使用kafka.<props>）或每个通道配置您的代理。

您可以将所有支持的 Kafka 属性传递给每个通道：

mp.messaging.incoming.chanel1.bootstrap.servers=kafka1:9092
mp.messaging.incoming.chanel2.bootstrap.servers=kafka2:9092