Spring Cloud Config集成Kafka实现微服务自动刷新失败求助

本地开发包含两个服务：

• config-server：连接Git仓库拉取配置属性
• product-service：依赖config-server获取配置

当前需求是实现Git配置变更后的自动刷新，已集成Docker化Kafka，但遇到以下问题：

• 调用config-server的/actuator/bus-refresh或/actuator/refresh接口时，既无法更新config-server自身配置，也无法触发product-service的配置刷新
• 直接调用product-service的/actuator/refresh接口，配置能正常更新

相关配置文件如下：

Config-server application.yaml #

server:
  port: 8071

spring:
  application:
    name: configserver
  profiles:
    active: git
  cloud:
    config:
      server:
        git:
          uri: "https://github.com/xxxx/swiftcart-config-store"
          searchPaths: "configs/{application},configs/common"
          cloneOnStart: true
        kafka:
          enabled: true
          topic: config-updates
          bootstrap-servers: "localhost:9092"
    bus:
      enabled: true  # Enable Spring Cloud Bus

product-service application.yaml #

server:
  port: 8081

spring:
  application:
    name: product-service
  profiles:
    active: dev
  config:
    import: "optional:configserver:http://localhost:8071/"
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      group-id: product-service-group
      auto-offset-reset: earliest
    template:
      default-topic: config-updates

  cloud:
    bus:
      enabled: true  # Enable Spring Cloud Bus

management:
  endpoints:
    web:
      exposure:
        include: "*"
  endpoint:
    health:
      show-details: always
    refresh:
      enabled: true

springdoc:
  api-docs:
    path: /v3/api-docs
  swagger-ui:
    path: /swagger-ui.html

logging:
  level:
    org.springframework.kafka: DEBUG
    org.apache.kafka: DEBUG

Docker compose.yaml（独立目录） #

version: '3.8'

services:
  kafka:
    image: confluentinc/cp-kafka:7.2.0
    ports:
      - "9092:9092"
    environment:
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
      - KAFKA_LISTENERS=PLAINTEXT:PLAINTEXT://0.0.0.0:9092,PLAINTEXT_HOST://0.0.0.0:29092
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:9092,PLAINTEXT_HOST://kafka:29092
      - KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR=1
      - KAFKA_GROUP_INITIAL_OFFSET_CONFIG=earliest
    networks:
      - swiftcart_network

  zookeeper:
    image: confluentinc/cp-zookeeper:7.2.0
    ports:
      - "2181:2181"
    environment:
      - ZOOKEEPER_CLIENT_PORT=2181
    networks:
      - swiftcart_network

  kafdrop:
    image: obsidiandynamics/kafdrop:latest
    ports:
      - "9000:9000"
    environment:
      - KAFKA_BROKERCONNECT=kafka:9092
    networks:
      - swiftcart_network

networks:
  swiftcart_network:
    driver: bridge

问题排查与解决方案 #

1. 检查Spring Cloud Bus依赖是否缺失 #

Spring Cloud Bus的Kafka支持需要引入对应的starter，确保两个服务的构建文件（pom.xml或build.gradle）中包含以下依赖：

Maven

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-bus-kafka</artifactId>
</dependency>

Gradle

implementation 'org.springframework.cloud:spring-cloud-starter-bus-kafka'

如果缺少该依赖，即使开启spring.cloud.bus.enabled=true也无法触发消息传递。

2. 修正Config Server的Kafka配置位置 #

当前config-server中spring.cloud.config.server.kafka的配置是用于将Kafka作为Config Server的配置存储后端（替代Git），但你实际使用的是Git作为配置源，这部分配置完全多余，且会干扰Spring Cloud Bus的正常工作。

删除spring.cloud.config.server.kafka节点，并为Config Server添加Spring Cloud Bus所需的Kafka配置：

修改后的config-server配置片段：

spring:
  # ... 其他配置
  kafka:
    bootstrap-servers: localhost:9092
    template:
      default-topic: config-updates
  cloud:
    config:
      server:
        git:
          uri: "https://github.com/xxxx/swiftcart-config-store"
          searchPaths: "configs/{application},configs/common"
          cloneOnStart: true
    bus:
      enabled: true

3. 暴露Config Server的Actuator端点 #

你的config-server配置中完全缺失management相关配置，默认情况下Actuator的bus-refresh和refresh端点是未暴露的，导致调用接口时无响应。

为config-server添加以下配置：

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

4. 验证Kafka Topic是否存在 #

使用Kafdrop访问http://localhost:9000，检查是否存在config-updates主题：

• 如果主题不存在，可手动创建，或确保Kafka的auto.create.topics.enable配置为true（你的Docker Compose中未修改此值，默认是true）。

5. 确保Config Server能刷新自身Git配置 #

Config Server默认不会自动拉取Git的最新配置，需添加以下配置来开启定时刷新或触发刷新时拉取：

spring:
  cloud:
    config:
      server:
        git:
          # 配置拉取间隔（单位：秒），比如每60秒拉取一次
          refresh-rate: 60

或者调用/actuator/refresh时，Config Server会触发一次Git拉取。

6. 检查服务与Kafka的连接状态 #

查看两个服务的日志（已开启Kafka DEBUG日志），确认是否成功连接到Kafka集群：

• 若出现连接超时或认证错误，检查Kafka的advertised.listeners配置是否正确（你的配置中PLAINTEXT://localhost:9092适合本地非容器化服务连接，没问题）。

内容的提问来源于stack exchange，提问作者Saphal Vecham