kafka streams log correlation 源码

使用Kafka流进行分布式跟踪 演示使用Sleuth进行标头传播时的Kafka流日志相关性。同伴项目到我 。 分布式跟踪是一种用于对应用程序进行概要分析和监视的方法,尤其是使用微服务体系结构构建的应用程序。分布式跟踪有助于查明发生故障的位置以及导致性能下降的原因。 [ ]应用于Kafka Streams,它允许我们通过在消息头中传播诊断信息来跟踪和可视化消息。 对Kafka Streams应用程序中的的全面支持是相当新的。它的中心,从提供Spring Boot AutoConfiguration。 Kafka Streams演示应用程序 为了演示使用Kafka Streams进行分布式跟踪,我。这个相当简单的演示应用程序使用数字输入流,然后将其分成两个分别的奇数和偶数主题。 无需任何跟踪,此应用程序将如下所示。 @Bean public KStream< String , Integ