fix(kafka): missing doublequote wrap of hash keys

thanks @shubham-html-css-js
redhat-performance · Dec 13, 2023 · 667afba · 667afba
1 parent 9f3d846
commit 667afba
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 16 deletions.
diff --git a/opl/consumer_lag.py b/opl/consumer_lag.py
@@ -26,15 +26,15 @@ def __init__(
     def _getconsumer(self):
         # Common parameters for both cases
         common_params = {
-            bootstrap_servers: self.bootstrap_servers,
-            auto_offset_reset: "latest",
-            enable_auto_commit: False,
-            max_poll_records: 50,
-            max_poll_interval_ms: 300000,
-            group_id: self.group,
-            session_timeout_ms: 50000,
-            heartbeat_interval_ms: 10000,
-            consumer_timeout_ms: 100000,
+            "bootstrap_servers": self.bootstrap_servers,
+            "auto_offset_reset": "latest",
+            "enable_auto_commit": False,
+            "max_poll_records": 50,
+            "max_poll_interval_ms": 300000,
+            "group_id": self.group,
+            "session_timeout_ms": 50000,
+            "heartbeat_interval_ms": 10000,
+            "consumer_timeout_ms": 100000,
         }
 
         # Kafka consumer creation: SASL or noauth

diff --git a/opl/skip_to_end.py b/opl/skip_to_end.py
@@ -23,13 +23,13 @@ def doit_seek_to_end(kafka_hosts, kafka_timeout, kafka_topic, kafka_group, args=
 
     # Common parameters for both cases
     common_params = {
-        bootstrap_servers: kafka_hosts,
-        auto_offset_reset: "latest",
-        enable_auto_commit: True,
-        group_id: kafka_group,
-        session_timeout_ms: 50000,
-        heartbeat_interval_ms: 10000,
-        consumer_timeout_ms: kafka_timeout,
+        "bootstrap_servers": kafka_hosts,
+        "auto_offset_reset": "latest",
+        "enable_auto_commit": True,
+        "group_id": kafka_group,
+        "session_timeout_ms": 50000,
+        "heartbeat_interval_ms": 10000,
+        "consumer_timeout_ms": kafka_timeout,
     }
 
     # Kafka consumer creation: SASL or noauth