diff --git a/ddtrace/contrib/internal/kafka/patch.py b/ddtrace/contrib/internal/kafka/patch.py index dff5853c599..07a70448498 100644 --- a/ddtrace/contrib/internal/kafka/patch.py +++ b/ddtrace/contrib/internal/kafka/patch.py @@ -270,7 +270,7 @@ def _instrument_message(messages, pin, start_ns, instance, err): cluster_id = _get_cluster_id(instance, str(first_message.topic())) core.set_item("kafka_cluster_id", cluster_id) core.set_item("kafka_topic", str(first_message.topic())) - core.dispatch("kafka.consume.start", (instance, first_message, span)) + core.dispatch("kafka.consume.start", (instance, message, span)) span.set_tag_str(MESSAGING_SYSTEM, kafkax.SERVICE) span.set_tag_str(COMPONENT, config.kafka.integration_name) diff --git a/releasenotes/notes/fix-kafka-consume-dispatch-48cd5912b1282ab9.yaml b/releasenotes/notes/fix-kafka-consume-dispatch-48cd5912b1282ab9.yaml new file mode 100644 index 00000000000..d303c04b9b4 --- /dev/null +++ b/releasenotes/notes/fix-kafka-consume-dispatch-48cd5912b1282ab9.yaml @@ -0,0 +1,4 @@ +--- +fixes: + - | + kafka: This fix resolves an issue where only the first message in a batch was dispatched to Data Streams Monitoring (DSM) when consuming multiple Kafka messages