我想尝试在spring Boot 3 Kafka生产者和消费者之间进行跟踪，我遵循了https://spring.io/blog/2022/10/12/observability-with-spring-boot-3中的示例。当我在生产者和消费者之间使用resttemplate进行API调用时，会自动添加traceID，但Kafka消息不携带它们。

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

        <dependency>
            <groupId>io.opentelemetry</groupId>
            <artifactId>opentelemetry-exporter-zipkin</artifactId>
        </dependency>
     <dependency>
            <groupId>org.springframework.kafka</groupId>
            <artifactId>spring-kafka</artifactId>
            <version>3.0.0</version>
        </dependency>

Kafka生产者结构

@Bean
public ProducerFactory<String, String> producerFactory() {
    Map<String, Object> configProps = new HashMap<>();
    //typical properties 
    return new DefaultKafkaProducerFactory<>(configProps);
}

@Bean
public KafkaTemplate<String, String> kafkaTemplate(ProducerFactory<String, String> producerFactory) {
    KafkaTemplate<String, String> stringStringKafkaTemplate = new KafkaTemplate<>(producerFactory);
    stringStringKafkaTemplate.setObservationEnabled(true);//trying out with
    return stringStringKafkaTemplate;
}

正在发送消息

kafkaTemplate.send("topic-1" , "message");

在消费者方面：

@KafkaListener(topics = "topic-1", groupId = "group1")
    public void listenGroupFoo(String message) {
        logger.info("Received Message in group foo: " + message);
    }

当我检查Kafka消息头时，每条消息都有traceparent头，但在使用者日志中看不到traceId和spanId