KafkaStreamTracing for flatMapValues

问题描述

如何使用 KafkaStreamTracing 来处理“flatMapValues”。我查看了 KafkaStreamTracing，但没有找到任何合适的方法来做到这一点。

我们已经在 kafka 流上构建了一个管道，需要使用 sleuth 启用分布式跟踪。

.mapValues(inboundDeserializer)
.filter(invalidaValuePredicate)
.flatMapValues(dataSplitter)
.mapValues(dataRule)

KafkaStreamsTracing 中有一些复杂管道的机制 -

   * builder.stream(inputTopic)
   *        .transformValues(kafkaStreamsTracing.mark("beginning-complex-map")
   *        .map(complexTransformation1)
   *        .filter(predicate)
   *        .mapValues(complexTransformation2)
   *        .transform(kafkaStreamsTracing.mark("end-complex-transformation")
   *        .to(outputTopic);

我尝试了上述标记，但无法记录 traceId 和 spanId。

请推荐

解决方法

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

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

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