fix(consumer_lag): Remove topic from KafkaConsumer config

it uses partitions_for_topic, no sub
redhat-performance · Dec 13, 2023 · 9f3d846 · 9f3d846
1 parent d2a9822
commit 9f3d846
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/opl/consumer_lag.py b/opl/consumer_lag.py
@@ -26,7 +26,6 @@ def __init__(
     def _getconsumer(self):
         # Common parameters for both cases
         common_params = {
-            topic: self.topic,
             bootstrap_servers: self.bootstrap_servers,
             auto_offset_reset: "latest",
             enable_auto_commit: False,