fix: Add Kafka

openedx · Mar 13, 2024 · 416a069 · 416a069
1 parent e273c4a
commit 416a069
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/platform_plugin_aspects/management/commands/monitor_load_test_tracking.py b/platform_plugin_aspects/management/commands/monitor_load_test_tracking.py
@@ -185,7 +185,7 @@ def get_kafka_bus_stats(self):
             low, high = consumer.get_watermark_offsets(partition, timeout=10, cached=False)
 
             if high < 0:
-                lag = "no hwmark"  # Unlikely
+                lag = 0
             elif partition.offset < 0:
                 # No committed offset, show total message count as lag.
                 # The actual message count may be lower due to compaction
@@ -194,7 +194,7 @@ def get_kafka_bus_stats(self):
             else:
                 lag = high - partition.offset
 
-            print(f"Kafka bus lag: {lag}")
+            print(f"{partition.topic} [{partition.partition}] Lag: {lag}")
 
             consumer_stats["partitions"].append({
                 "partition": partition.partition,