Spring Kafka 3追踪配置异常：无法生成Kafka链路追踪Span

问题 #

• Jaeger中仅显示S3交互Span，Kafka相关Span完全缺失
• Kafka Topic中的消息未携带spanId/traceId等链路追踪头信息

已完成配置 #

代码设置 #

kafkaTemplate.setObservationEnabled(true);

application.properties配置 #

management.tracing.enabled=true
management.tracing.sampling.probability=1.0
management.tracing.propagation.type=w3c
management.tracing.propagation.produce=w3c
management.tracing.propagation.consume=w3c
management.otlp.tracing.endpoint=http://localhost:4318/v1/traces

依赖配置（Spring Boot 3.2.1 + Spring Kafka 3.1.1） #

<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-tracing</artifactId>
</dependency>

<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-tracing-bridge-otel</artifactId>
    <version>1.2.3</version>
</dependency>
<dependency>
    <groupId>io.opentelemetry</groupId>
    <artifactId>opentelemetry-exporter-otlp</artifactId>
</dependency>

修复步骤 #

1. 对齐依赖版本
   Spring Boot 3.2.x默认管理的micrometer-tracing-bridge-otel版本为1.3.x，手动指定的1.2.3存在兼容性问题，移除版本号让Spring Boot自动管理依赖：

   <dependency>
       <groupId>io.micrometer</groupId>
       <artifactId>micrometer-tracing-bridge-otel</artifactId>
   </dependency>
   

2. 启用Producer Factory观测能力
   仅开启KafkaTemplate的观测不够，需同时为底层DefaultKafkaProducerFactory启用观测：

   @Bean
   public ProducerFactory<String, Object> producerFactory() {
       Map<String, Object> configs = new HashMap<>();
       configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "你的Kafka集群地址");
       // 其他生产者配置
       DefaultKafkaProducerFactory<String, Object> factory = new DefaultKafkaProducerFactory<>(configs);
       factory.setObservationEnabled(true); // 关键配置
       return factory;
   }
   
   @Bean
   public KafkaTemplate<String, Object> kafkaTemplate() {
       KafkaTemplate<String, Object> template = new KafkaTemplate<>(producerFactory());
       template.setObservationEnabled(true);
       return template;
   }
   

3. 添加Spring Kafka Micrometer集成依赖
   Spring Kafka 3.1.x需要该依赖实现与链路追踪的绑定，负责生成Kafka发送/接收Span并传播追踪头：

   <dependency>
       <groupId>org.springframework.kafka</groupId>
       <artifactId>spring-kafka-micrometer</artifactId>
   </dependency>
   

4. 简化配置属性
   management.tracing.propagation.type=w3c已覆盖produce和consume的传播规则，可简化配置文件：

   management.tracing.enabled=true
   management.tracing.sampling.probability=1.0
   management.tracing.propagation.type=w3c
   management.otlp.tracing.endpoint=http://localhost:4318/v1/traces
   

5. 验证Jaeger OTLP接收器状态
   确保Jaeger启动时开启OTLP接收器，默认4318端口为HTTP协议端点，启动命令示例：

   jaeger-all-in-one --collector.otlp.enabled=true
   

验证方式 #

• 发送消息后检查Kafka消息头，应存在traceparent（W3C格式）追踪头
• 查看Jaeger UI，应出现kafka.producer类型的Span，且与S3交互Span属于同一Trace链路

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