如何解决如何在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 举报,一经查实,本站将立刻删除。