如何通过春季云流配置两组独立的kafka代理以及zipkin？

问题描述

我必须配置两个单独的Kafka代理（如下例所示），并且工作正常-我在不同的Kafka上进行读写操作。

spring:
  cloud:
    stream:
      binders:
        kafka1:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers: dev1-stage.dub:9092
        kafka2:
          type: kafka
          environment:
            spring:
              cloud:
                stream:
                  kafka:
                    binder:
                      brokers: dev2-stage.dub:9092
      bindings:
        firstOut:
          destination: first_topic
          binder: kafka1
        secondOut:
          destination: second_topic
          binder: kafka2

但是我还需要在应用程序中配置zipkin + sleuth-唯一的方法是通过添加：

spring:
  kafka:
    bootstrap-servers: dev1-stage.dub:9092

添加 spring.kafka.bootstrap-服务器后，它开始覆盖 kafka2.environment.spring.cloud.stream.kafka.binder.brokers -因此，应用程序只是尝试在dev1-stage.dub而不是dev2-stage.dub上写kafka。

如何防止这种覆盖？还是我应该重新配置以支持zipkin和kafka代理这两个集合？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）