Skip to content
Open
Show file tree
Hide file tree
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ddtrace/contrib/internal/kafka/patch.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
Original file line number Diff line number Diff line change
@@ -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
Loading