小编Tri*_*e S的帖子

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

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

在应用程序配置(yaml)中我们设置Kafka服务器(broker):

kafka:
  bootstrap:
    servers: localhost:9092
Run Code Online (Sandbox Code Playgroud)

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

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

java apache-kafka quarkus smallrye-reactive-messaging

1
推荐指数
1
解决办法
1826
查看次数