configserver上的spring cloud starter bus kafka安装程序

Question

亲爱的Spring开发者！

我想从官方文档和示例代码中设置spring cloud configserver。它适合我，如果我更改它，我想在运行时刷新我的属性github。

我已经添加了spring-cloud d-config-监视依赖项，我想使用Kafka进行更改事件广播。我在文档中阅读过，这是可能的，但我无法配置配置服务器的spring-cloud d-starter-bus-kafka和客户端的spring-cloud d-starter-bus-kafka。

我还使用了zooeger，和docker中的kafka，它工作得很好。

有人能帮我关于如何配置kafka总线配置服务器和配置客户端吗？

谢谢

Answer 1

spring:
  cloud:      
    bus:     
      enabled: true
    stream:
      kafka:
        binder:
          zkNodes: localhost:9092,127.0.0.1:9092
          brokers: localhost:2181,127.0.01:2181

Answer 2

spring:
  cloud:
    stream:
      kafka:
        binder:
          brokers: host1:port1,host2:port2
          zkNodes: host1:port1,host2:port2
          zkSessionTimeout: 6000

这对我有用。如果要配置外部Kafka代理，则默认情况下，配置应为spring cloud Kafka connector的约定。