如何通过SpringCloudStream配置两组独立的kafka代理和zipkin?

z31licg0  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(313)

我必须配置两个独立的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-servers添加后,它就开始覆盖kafka2.environment.spring.cloud.stream.kafka.binder.brokers—所以应用程序只是尝试在dev1-stage.dub上写入kafka,而不是dev2-stage.dub。
如何防止这种覆盖?或者我应该如何修改配置以支持两组kafka代理和zipkin?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题