Spring Boot 3.x结合Spring Cloud Stream 4.x实现Kafka链路日志关联

核心结论 #

StreamBridge 和 Spring Cloud Stream Kafka 生产者/消费者默认支持 Micrometer Tracing 自动埋点，你的问题大概率是依赖缺失、配置未到位或版本不匹配导致的，无需手动修改 ApplicationContext 这类风险操作。

1. 依赖配置（必做） #

确保引入以下核心依赖（版本对应 Spring Boot 3.x + Spring Cloud 2022.0.x 系列）：

<!-- Spring Cloud Stream Kafka Binder -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-kafka</artifactId>
</dependency>
<!-- Micrometer Tracing 核心依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-tracing-bridge-b3</artifactId>
</dependency>
<!-- 可选：若需上报追踪数据到监控系统，比如Zipkin -->
<dependency>
    <groupId>io.zipkin.reporter2</groupId>
    <artifactId>zipkin-reporter-brave</artifactId>
</dependency>

2. 关键配置项 #

在 application.yml 或 application.properties 中添加以下配置：

# 开启链路追踪的B3格式（兼容原Sleuth的传递逻辑）
management:
  tracing:
    propagation:
      type: b3
# 全局开启Spring Cloud Stream Kafka Binder的观测功能
spring:
  cloud:
    stream:
      kafka:
        binder:
          observation:
            enabled: true
      # 针对具体绑定的生产者/消费者开启观测（全局开启后可省略）
      bindings:
        # 示例：StreamBridge使用的输出绑定
        your-output-binding:
          producer:
            observation:
              enabled: true
        # 示例：KStream消费的输入绑定
        your-input-binding:
          consumer:
            observation:
              enabled: true

3. 解决 KafkaTemplate ObservationRegistry 为 NOOP 的问题 #

你遇到的 KafkaTemplate 初始化时 ObservationRegistry 为 NOOP 的情况，本质是依赖未正确引入导致自动配置失效：

• 只要确保引入了 micrometer-tracing-bridge-b3 和 spring-boot-starter-actuator，Spring Boot 自动配置会将 ObservationRegistry 实例化为正常工作的 Bean，而非 NOOP。
• 禁止手动修改 ApplicationContext 或 KafkaTemplate 的初始化逻辑，避免破坏原有 Kafka 集群配置。

4. 消费者端（KStream）关联 MDC 日志 #

配置完成后，消费者会自动提取消息头中的 b3 信息并注入到 MDC 中，无需额外代码。若仍无法关联，检查：

• 输入绑定是否开启了 observation.enabled=true
• 消息是否携带 b3 头（可通过 Kafka 控制台或工具查看）
• 日志配置是否正确输出 MDC 中的 traceId 和 spanId，比如 Logback 配置：

<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} traceId=%X{traceId}, spanId=%X{spanId} - %msg%n</pattern>

5. 常见误区 #

• 版本不匹配：Spring Boot 3.x 必须搭配 Spring Cloud 2022.0.x（Kilburn 版本），否则会出现自动配置失效问题。
• 手动创建 KafkaTemplate：若自行实例化 KafkaTemplate，需手动注入 ObservationRegistry，但 StreamBridge 依赖的是 Binder 提供的 KafkaTemplate，无需额外处理。
• 未指定传播格式：默认 Micrometer Tracing 使用 W3C 格式，若要兼容原 Sleuth 的 B3 格式，必须配置 management.tracing.propagation.type=b3。

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