【发布时间】:2021-09-03 21:17:12
【问题描述】:
如何使用 Spring Cloud sleuth 跟踪基于 Kafka 的事件?我看到的任何示例都是针对其他 API 的。我正在寻找 kafka-clients 库。
为此使用 Spring cloud sleuth 也是一个好主意,还是应该手动通过标头传递我的 traceId?
【问题讨论】:
标签: apache-kafka microservices spring-cloud-sleuth
如何使用 Spring Cloud sleuth 跟踪基于 Kafka 的事件?我看到的任何示例都是针对其他 API 的。我正在寻找 kafka-clients 库。
为此使用 Spring cloud sleuth 也是一个好主意,还是应该手动通过标头传递我的 traceId?
【问题讨论】:
标签: apache-kafka microservices spring-cloud-sleuth
从 Spring Cloud Sleuth 文档 here 中可以看出,Kafka Streams 提供了集成(Sleuth 内部使用库 Brave 进行检测)。可以通过它启用/禁用的属性是spring.sleuth.messaging.kafka.streams.enabled (true/false)
我们检测 KafkaStreams KafkaClientSupplier 以便跟踪 标头被注入生产者和消费者的。一种 KafkaStreamsTracing bean 允许通过进一步检测 额外的 TransformerSupplier 和 ProcessorSupplier 方法。
有关示例配置/代码,您可以查看here。
【讨论】: