From 6cbb983520f2514518feda863391798cf3bd2171 Mon Sep 17 00:00:00 2001 From: "diana.shevchenko" Date: Thu, 28 Jul 2022 14:46:37 +0200 Subject: [PATCH] contrib/segmentio: resource name uses topic name from message if writer topic is empty --- contrib/segmentio/kafka.go.v0/kafka.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/contrib/segmentio/kafka.go.v0/kafka.go b/contrib/segmentio/kafka.go.v0/kafka.go index ff7b81edb0..458bb40675 100644 --- a/contrib/segmentio/kafka.go.v0/kafka.go +++ b/contrib/segmentio/kafka.go.v0/kafka.go @@ -127,9 +127,13 @@ type Writer struct { func (w *Writer) startSpan(ctx context.Context, msg *kafka.Message) ddtrace.Span { opts := []tracer.StartSpanOption{ tracer.ServiceName(w.cfg.producerServiceName), - tracer.ResourceName("Produce Topic " + w.Writer.Topic), tracer.SpanType(ext.SpanTypeMessageProducer), } + if w.Writer.Topic != "" { + opts = append(opts, tracer.ResourceName("Produce Topic "+w.Writer.Topic)) + } else { + opts = append(opts, tracer.ResourceName("Produce Topic "+msg.Topic)) + } if !math.IsNaN(w.cfg.analyticsRate) { opts = append(opts, tracer.Tag(ext.EventSampleRate, w.cfg.analyticsRate)) }