lib/opentelemetry/instrumentation/ruby_kafka/patches/producer.rb in opentelemetry-instrumentation-ruby_kafka-0.13.0 vs lib/opentelemetry/instrumentation/ruby_kafka/patches/producer.rb in opentelemetry-instrumentation-ruby_kafka-0.14.0
- old
+ new
@@ -16,10 +16,10 @@
'messaging.destination' => topic,
'messaging.destination_kind' => 'topic'
}
tracer.in_span("#{topic} send", attributes: attributes, kind: :producer) do
- OpenTelemetry.propagation.text.inject(headers)
+ OpenTelemetry.propagation.inject(headers)
super
end
end
private