lib/opentelemetry/instrumentation/ruby_kafka/patches/client.rb in opentelemetry-instrumentation-ruby_kafka-0.20.2 vs lib/opentelemetry/instrumentation/ruby_kafka/patches/client.rb in opentelemetry-instrumentation-ruby_kafka-0.21.0

@@ -22,10 +22,10 @@
             message_key = Utils.extract_message_key(key)
             attributes['messaging.kafka.message_key'] = message_key if message_key
 
             attributes['messaging.kafka.partition'] = partition if partition
 
-            tracer.in_span("#{topic} send", attributes: attributes, kind: :producer) do
+            tracer.in_span("#{topic} publish", attributes: attributes, kind: :producer) do
               OpenTelemetry.propagation.inject(headers)
               super
             end
           end