diff --git a/consumers/tracing/consumers.go b/consumers/tracing/consumers.go index e7ad4a64d04..da3fc6e15b8 100644 --- a/consumers/tracing/consumers.go +++ b/consumers/tracing/consumers.go @@ -84,7 +84,7 @@ func createMessageSpan(ctx context.Context, tracer opentracing.Tracer, topic, su span, ctx := opentracing.StartSpanFromContextWithTracer(ctx, tracer, operation, ext.SpanKindConsumer) span.SetTag("topic", topic) if subTopic != "" { - span.SetTag("sub-topic", subTopic) + span.SetTag("subtopic", subTopic) } span.SetTag("publisher", publisher) span.SetTag("number_of_messages", noMessages)