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



亲爱的Spring开发者!

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

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

我还使用了动物园管理员和 docker 中的 kafka,效果很好。

谁能帮我配置卡夫卡总线到配置服务器和配置客户端

谢谢

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

这对我有用。如果要配置外部 Kafka 代理,则配置应默认为春季云 kafka 连接器约定。

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

最新更新