Spring Cloud Sleuth不同跟踪ID与Kafka集成

Question

我使用Kafka来实现微服务之间的呼叫同步，并使用SpringSleuth进行日志记录。日志记录是可以的，但是当有一条消息从MicroService 1发送到MicroService 2时，日志记录的消息具有不同的跟踪ID。它们不是必须具有相同的跟踪ID但具有不同的SpanId吗？是否有任何特殊配置？

Answer 1

默认情况下，Spring Cloud Kafka活页夹不会传输消息头，您必须通过Spring进行设置。云流动Kafka。粘合剂标题如Spring Cloud Stream参考指南中所述手动设置。然后检查那些与跟踪相关的头文件是否已正确发送。

您可以在application.yml中设置Zipkin标题如下：

spring:
  cloud:
    stream:
      kafka:
        binder:
          headers:
            - X-B3-TraceId
            - X-B3-SpanId
            - X-B3-Sampled
            - X-B3-ParentSpanId
            - X-Span-Name
            - X-Span-Export

或者在你的application.properties：

spring.cloud.stream.kafka.binder.headers[0]=X-B3-TraceId
spring.cloud.stream.kafka.binder.headers[1]=X-B3-SpanId
spring.cloud.stream.kafka.binder.headers[2]=B3-Sampled
spring.cloud.stream.kafka.binder.headers[3]=X-B3-ParentSpanId
spring.cloud.stream.kafka.binder.headers[4]=X-Span-Name
spring.cloud.stream.kafka.binder.headers[5]=X-Span-Export

或在逗号分隔的列表中：

spring.cloud.stream.kafka.binder.headers=X-B3-TraceId,X-B3-SpanId,B3-Sampled,\
    X-B3-ParentSpanId,X-Span-Name,X-Span-Export