diff --git a/CHANGELOG.md b/CHANGELOG.md index 8818f8b070..5ca46e3458 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -16,6 +16,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - Bump `pylint` to `4.0.5` ([#4244](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4244)) +### Fixed + +- `opentelemetry-instrumentation-confluent-kafka`: Use `PUBLISH` messaging operation name for producer spans (was incorrectly `CREATE`), aligning with the semantic conventions + ([#4435](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/4435)) + ### Breaking changes - Drop Python 3.9 support diff --git a/instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py b/instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py index ed390d7006..8c0fde7688 100644 --- a/instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py +++ b/instrumentation/opentelemetry-instrumentation-confluent-kafka/src/opentelemetry/instrumentation/confluent_kafka/__init__.py @@ -370,8 +370,8 @@ def wrap_produce(func, instance, tracer, args, kwargs): _enrich_span( span, topic, - operation=MessagingOperationTypeValues.RECEIVE, - ) # Replace + operation=MessagingOperationTypeValues.PUBLISH, + ) propagate.inject( headers, setter=_kafka_setter,