使用 Jaeger 跟踪分布式应用程序中的 Kafka 总线

Question

我有一个由多个 Go 服务组成的分发应用程序。其中一些使用 Kafka 作为数据总线。opentracing我能够使用Jaeger追踪服务之间的调用。我在图表上绘制 Kafka 跨度时遇到问题，它们显示为间隙。

这就是我能做的。初始跨度由 gRPC 中间件创建。生产方：

...    

kafkaMsg := kafka.Message{Key: []byte(key), Value: msgBytes}

headers:=make(map[string]string)

if span := opentracing.SpanFromContext(ctx); span != nil {

    opentracing.GlobalTracer().Inject(

        span.Context(),

        opentracing.TextMap,

        opentracing.TextMapCarrier(headers))

}

for headerKey, headerValue:=range headers{

    msg.Headers = append(msg.Headers, kafka.Header{

        Key: headerKey,

        Value: []byte(headerValue),

    })

}

// Write message to Kafka

...

消费端：

...

// read headers from Kafka message

headers := make(map[string]string)

for _, header := range kafkaMessage.Headers{

    headers[header.Key]=string(header.Value)

}

spanContext, _ := opentracing.GlobalTracer().Extract(opentracing.TextMap, opentracing.TextMapCarrier(headers))

span := opentracing.StartSpan(

    "Consumer",

    opentracing.FollowsFrom(spanContext))

defer span.Finish()

...

当消息位于 Kafka 中时，我应该如何修改它以在图表上绘制跨度？

Answer 1

Jaeger 不支持跨系统跨度。每个子系统对整个系统中自己的跨度负责。