Spring Cloud他のトレースIDがKafkaと統合

Question

私はマイクロサービス間のAsyng呼び出しにKafkaを使用していますが、私はロギングにSpring Sleuthを使用しています。ロギングは正常ですが、Microservice1からMicroservice2へのメッセージがある場合、ロギングのメッセージには異なるTrace-IDがあります。彼らは同じトレースIDを持っている必要はありませんが、別のSpanIdを持っていませんか？特別な構成はありますか？

Answer 1

デフォルトでは、メッセージヘッダーはSpring Cloud Kafkaバインダーによって移送されません。の説明に従って、spring.cloud.stream.kafka.binder.headersを手動で設定する必要があります。トレースに関連するヘッダーが正しく送信されているかどうかを確認します。

あなたの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