如何使用Spring Cloud Sleuth追踪Kafka流
如何使用Spring Cloud sleuth跟踪基于Kafka的事件？我看到的例子都是RESTAPI。我在找Kafka客户图书馆。
另外，使用Spring cloud sleuth是一个好主意还是应该手动通过标头传递我的TraceID？
共有1个答案
从Spring Cloud Sleuth留档中，它说集成是与Kafka Streams一起提供的（Sleuth内部使用库Brave进行检测）。可以启用/禁用它的属性是spring.sleuth.messaging.kafka.streams.enabled（true/false）
我们对KafkaStreams KafkaClientSupplier进行了测试，以便将跟踪头注入生产者和消费者的。KafkaStreamsTracing bean允许通过额外的TransformerSupplier和ProcessorSupplier方法进行进一步的检测。
有关示例配置/代码，您可以在此处查看。
-
我正在使用Brave库https://github.com/openzipkin/brave进行跟踪，现在我也想将其用于Kafka消费者。我想避免添加Spring Sleuth，并利用Brave Kafka仪器https://github.com/openzipkin/brave/tree/master/instrumentation/kafka-clients. 对于Kafka消费者，我使用@K
-
我在一个公认的缓慢配置中设置了Kafka——但我不期待我看到的数字。 我将集群设置为＜code＞LogAppendTime＜/code＞，因此我正在测量事件写入Kafka（由代理决定）与服务接收到事件之间的时间。代理和应用程序都位于“同一位置”，因此服务器之间的ping时间很短，时钟应该同步或接近。 我看到延迟在 到 600ms 之间，很多是 ......巨大的差异让我觉得我的设置出了问题。它因消
-
当你把一个普通的 JavaScript 对象传给 Vue 实例的data选项，Vue 将遍历此对象所有的属性，并使用Object.defineProperty把这些属性全部转为 getter/setter。Object.defineProperty 是 ES5 中一个无法 shim 的特性，这也就是为什么 Vue 不支持 IE8 以及更低版本浏览器的原因。 这些 getter/setter 对用户
-
我有一个由API网关事件触发的AWS Lambda函数。API网关配置为使用X射线。 由于Lambda跟踪配置默认为PassTour，因此它也会显示在X射线（服务地图等）中。 被调用的Lambda使用节点。js aws sdk调用另一个lambda。如果我理解正确，则必须将跟踪ID传递给下一次调用，以便在X射线中也显示此Lambda。在SDK的API中，我没有找到此选项。 我怎样才能做到这一点？如
-
在微服务场景下，我们会拆分出来很多的服务，也就意味着一个业务请求，少则跨越 3-4 个服务，多则几十个甚至更多，在这种架构下我们需要对某一个问题进行 Debug 的时候是极其困难的一件事情，那么我们就需要一个调用链追踪系统来帮助我们动态地展示服务调用的链路，以便我们可以快速地对问题点进行定位，亦可根据链路信息对服务进行调优。 在 Hyperf 里我们提供了 hyperf/tracer 组件来对各个
-
感谢你在这个问题上的帮助。 我使用的是Kafka 0.8.2 这是我写的制作人代码。