如何在Kafka使用者中使用Spring Cloud Sleuth TraceId

问题描述

我正在使用springboot 2.3.4，对应的spring-kafka 2.5.6.RELEASE，springcloud sleuth 2.2.5， 我使用@KafkaListener来监听Kafka消息，但是在测试过程中，我发现生产者具有traceId，并且我需要使用者生成新的traceId，但是不幸的是，日志打印中没有traceId。我是新手，这让我很困惑。我需要启用某些配置，还是需要自己实施跟踪？ 谢谢！

 @KafkaListener( topics = {"#{'${kafka.topics}'}"},containerFactory = "batchMessageFactory")
    public void onMessage(List<ConsumerRecord<String,String>> records) {
        if(!CollectionUtils.isEmpty(records)) {
         
            records.stream().forEach(record -> {
                String message = record.value();
                log.info("messge:{}",message)
            }
            });
        }

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）