为什么Kafka producerListener没有记录跟踪id和span id？

Question

我有一个Kafka实例和一个简单的Spring Boot应用程序，其中有一个REST控制器和一个ProducerListenerbean。控制器接受一个简单的字符串消息，并通过KafkaTemplate将其发送给Kafka。我想让ProducerListener记录一条信息消息，但缺少跟踪id和span id。在我看来，它应该包括在日志中。

我使用SpringCloud侦探和SpringKafka启动器。

消息本身通过Kafka主题成功发送到另一个正确获取跟踪标识的Spring Boot应用程序，所以我假设这个问题只与producerListener有关。

我试过调试代码，结果是使用了方法TracingProducer。发送（…） 。那里的span实例是NoopSpan（这很奇怪），因为TracingCallback没有包装回调，跟踪信息丢失。有一些讨厌的比特操作我不明白。jar就是这个brave-instrumentation-kafka-clients-5.7.0。jar

控制器

@PostMapping("/pass-to-kafka")
public void passToKafka(@RequestBody String message) {
   logger.info("This log message has trace id and span id");
   kafkaTemplate.send("my-test-topic", message);
}

制片人听众

@Bean
public ProducerListener myProducerListener() {
    return new ProducerListener<>() {
        @Override
        public void onSuccess(ProducerRecord producerRecord, RecordMetadata recordMetadata) { 
            logger.info("This log message is missing trace id and span id");
        }
    };
}

代码为的项目位于GitHub上：https://github.com/vaclavnemec/kafka-sleuth-problem

我希望信息消息写出跟踪id和跨度id。这两个记录器中的值应该相同。

INFO [bar,208706b5c40f8e93,208706b5c40f8e93,false] com.example.demo.Controller: This log message has trace id and span id
.
.
.
INFO [bar,,,] com.example.demo.DemoApplication: This log message is missing trace id and span id




Answer 1

请设置spring.sleuth.probability=1.0如留档和自述文件所述。然后你会打开追踪。