Skip to content

Commit 527ae8a

Browse files
committed
fix(confluent-kafka): use PUBLISH operation for producer spans
wrap_produce was setting messaging.operation=RECEIVE on producer spans. The correct OTel semantic value for a send/produce operation is PUBLISH. Fixes #4292 Signed-off-by: alliasgher <alliasgher123@gmail.com>
1 parent 34bfc28 commit 527ae8a

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

  • instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka

instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -370,8 +370,8 @@ def wrap_produce(func, instance, tracer, args, kwargs):
370370
_enrich_span(
371371
span,
372372
topic,
373-
operation=MessagingOperationTypeValues.RECEIVE,
374-
) # Replace
373+
operation=MessagingOperationTypeValues.PUBLISH,
374+
)
375375
propagate.inject(
376376
headers,
377377
setter=_kafka_setter,

0 commit comments

Comments
 (0)