Spring Cloud Sleuth，Kafka标签和数据关注

问题描述

我使用最新的Spring Boot 2.4.0.m3设置Spring Sleuth。在Zipkin上，来自源的数据流出被定向到“代理”。以下是代码捕捉：

fooService
    .output()
    .send(MessageBuilder.withPayload(payloadString).build());

其中fooService是org.springframework.cloud.stream.messaging.source数据类型。

接收器连接到“ Kafka”。而且“经纪人”和“卡夫卡”之间没有联系。而且，接收器有数据流出到“ Kafka”。以下是代码捕捉：

@StreamListener(Sink.INPUT)
public void consumeNewMessage(String msg) {
    log.info("Received Kafka message: {}",msg);
    ...
} 

在我看来，图片中有两个错误。一种是“经纪人”的标签。它也应该是“ Kafka”。而且接收器应该具有来自Kafka的流入数据，而不是流出的数据。解决这两个错误是否需要其他配置？

解决方法

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

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

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