Spring Cloud Stream：同一个应用程序中的两个不同的Kafka

Question

我正在尝试在同一个应用中使用两个不同的 Kafka。

当我只有一个 Kafka 时，我的 application.yml 是：

spring:
  cloud:
    stream:
       kafka:
         binder:
           brokers: kafka_broker01
           zkNodes: kafka_broker01
           headers: type

       binders:
         some-binder:
           type: kafka
           inheritEnviroment: true

但我不知道该怎么做，以防我有一些其他 Kafka 服务器要在绑定中引用：

  kafka:
    binder:
      brokers: other_kafka_broker01
      zkNodes: other_kafka_broker01
      headers: type

如何重新排列属性？

提前致谢。

Answer 1

您的问题太笼统了，所以我建议您先查看 Multibinder samples，其中包括包括 Kafka 在内的多个变体。在reference manual 中有更多关于多活页夹支持的信息和细节。