在configserver上安装spring云启动器-bus-kafka

Question

亲爱的春天开发者！

我想从正式文档和示例代码中设置。它对我有用，如果我更改了github，我想在运行时刷新我的属性。

我已经添加了spring云配置监视器依赖项，并且我希望使用Kafka来进行事件广播。我在文档中读到，这是可能的，但我不能配置configserver的bus-kafka和客户的spring-cloud-starter bus-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代理，那么配置应该默认为连接器。