时间戳

首页 > 解决方案 > 如何使用 Spring Cloud Sleuth 跟踪 Kafka 流

apache-kafka - 如何使用 Spring Cloud Sleuth 跟踪 Kafka 流

问题描述

如何使用 Spring Cloud sleuth 跟踪基于 Kafka 的事件？我看到的任何示例都是针对其他 API 的。我正在寻找 kafka-clients 库。

使用 Spring cloud sleuth 也是一个好主意，还是应该手动通过 headers 传递我的 traceIds？

标签： apache-kafkamicroservicesspring-cloud-sleuth

解决方案

从这里的 Spring Cloud Sleuth 文档中可以看出，Kafka Streams 提供了集成（Sleuth 内部使用库Brave进行检测）。可以通过它启用/禁用的属性是spring.sleuth.messaging.kafka.streams.enabled（真/假）

我们对 KafkaStreams KafkaClientSupplier 进行检测，以便将跟踪标头注入到生产者和消费者中。KafkaStreamsTracing bean 允许通过额外的 TransformerSupplier 和 ProcessorSupplier 方法进行进一步检测。

对于示例配置/代码，您可以查看此处。

推荐阅读