我必须配置两个独立的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?
暂无答案!
目前还没有任何答案,快来回答吧!