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

来源:6-5 Spring Cloud Bus实操.mp4

李航宇

2019-06-02

师兄能帮我看看这个自动刷新配置 用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

师兄能帮忙瞧瞧吗?

写回答

1回答

廖师兄

2019-06-02

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

0
2
廖师兄
回复
李航宇
我没有用过kafka,要不你去spring-cloud-bus的github上问一下
2019-06-04
共2条回复

SpringCloud Finchley(M2+RELEASE+SR2)微服务实战

SpringCloud组件实现微服务,【已升级Finchley.Release】

5668 学习 · 2489 问题

查看课程