Update kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py

Co-authored-by: Andrew Zhang <andrew.zhang@datadoghq.com>
DataDog · Mar 15, 2023 · 025c343 · 025c343
1 parent 5674f27
commit 025c343
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py b/kafka_consumer/datadog_checks/kafka_consumer/kafka_consumer.py
@@ -46,6 +46,8 @@ def check(self, _):
         highwater_offsets = {}
         try:
             if len(consumer_offsets) < self._context_limit:
+                # Fetch highwater offsets
+                # Expected format: {(topic, partition): offset}
                 highwater_offsets = self.client.get_highwater_offsets(consumer_offsets)
             else:
                 self.warning("Context limit reached. Skipping highwater offset collection.")