springcloud Bus 自动刷新配置 + kafka 问题

Question

师兄能帮我看看这个自动刷新配置 用kafka的问题？

这个是我config配置中心启动时，有将bus-refresh暴露出来

这个config配置中心启动kafka创建的topic：springcloudbus

kafka启动读取配置 192.168.1.101：9092是我虚机地址，也是broker地址

这个是我微服务端启动暴露bus-refresh 和 接收到topic：springcloudbus

git端配置 env ：dev6

获取localhost:8080/env/output 成功获取到 env：dev6

此刻去git远端更改env：dev10

通过docker 输入：curl -v -X POST "http://localhost:9091/actuator/bus-refresh"报错了
并且服务端也没有请求：Fetching config from server at : http://localhost:9091/

我的配置文件如下
config端：

    bus:
      trace:
        enabled: true
    stream:
      kafka:
        binder:
          brokers: 192.168.1.101:9092
management:
  endpoints:
    web:
      exposure:
        include: '*'

server服务端：

    bus:
      trace:
        enabled: true
    stream:
      kafka:
        binder:
          brokers: 192.168.1.101:9092

management:
  endpoints:
    web:
      exposure:
        include: bus-refresh
  endpoint:
      bus-refresh:
        enabled: true

师兄能帮忙瞧瞧吗？

Answer 1

廖师兄 2019-06-02 23:33:05

bus组件自动刷新这里有bug， 我课程里说了，我用rabbitmq一样的问题。你是生产环境要是使用吗？

• 提问者 李航宇 #1

  师兄，我用mq后是可以正常的修改，但是因我的项目需要用到kafka，因此碰到这个问题，有点不知道怎么搞，我看config端和server都有收到topic，可是用curl -v -X POST时如上图出现的情况，那我用kafka现在应该怎么操作这里。

• 廖师兄 回复 提问者 李航宇 #2

  我没有用过kafka，要不你去spring-cloud-bus的github上问一下