spring-cloud-starter-bus-kafka 配置服务器上的设置

Question

尊敬的 Spring 开发人员！

我想根据官方文档和示例代码设置 spring 云配置服务器。它对我有用，如果我更改它，我想在运行时刷新我的属性 github。

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

我也用过zookeeper，还有docker的kafka，效果不错

谁能帮我 如何配置 kafka 总线到 configserver 和 configclient？

谢谢

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 云 kafka 连接器。

spring-cloud-starter-bus-kafka 配置服务器上的设置

spring-cloud-starter-bus-kafka setup on configserver

spring

configserver