[kafka_consumer] Add bootstrap_servers to heartbeat payload (DataDog#23475)

piochelepiotr · claude · web-flow · commit 6597bfdf3d97 · 2026-04-25T23:39:32.000Z
* [kafka_consumer] Add bootstrap_servers to heartbeat payload

Co-Authored-By: Claude Opus 4.7 (1M context) &lt;noreply@anthropic.com&gt;

* Rename changelog fragment to PR number

Co-Authored-By: Claude Opus 4.7 (1M context) &lt;noreply@anthropic.com&gt;

---------

Co-authored-by: Claude Opus 4.7 (1M context) &lt;noreply@anthropic.com&gt;
diff --git a/kafka_consumer/changelog.d/23475.added b/kafka_consumer/changelog.d/23475.added
@@ -0,0 +1 @@
+Include `bootstrap_servers` in the Kafka consumer cluster monitoring heartbeat payload.
diff --git a/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py b/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py
@@ -149,6 +149,7 @@ def _send_cluster_monitoring_heartbeat(self, total_contexts: int, cluster_id: st
             'config_type': 'heartbeat',
             'contexts': total_contexts,
             'contexts_limit': self._context_limit,
+            'bootstrap_servers': self.config._kafka_connect_str,
         }
         if self.config._kafka_cluster_id_override:
             payload['original_kafka_cluster_id'] = self.config._auto_detected_cluster_id

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	+Include `bootstrap_servers` in the Kafka consumer cluster monitoring heartbeat payload.
Original file line number	Diff line number	Diff line change
`@@ -149,6 +149,7 @@ def _send_cluster_monitoring_heartbeat(self, total_contexts: int, cluster_id: st`
`149`	`149`	`'config_type': 'heartbeat',`
`150`	`150`	`'contexts': total_contexts,`
`151`	`151`	`'contexts_limit': self._context_limit,`
	`152`	`+ 'bootstrap_servers': self.config._kafka_connect_str,`
`152`	`153`	`}`
`153`	`154`	`if self.config._kafka_cluster_id_override:`
`154`	`155`	`payload['original_kafka_cluster_id'] = self.config._auto_detected_cluster_id`