Fix typo in parameter name

astrolabsoftware · Jun 4, 2024 · afd138c · afd138c
1 parent 03f62f8
commit afd138c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/test.py b/tests/test.py
@@ -56,7 +56,7 @@ def setUp(self):
 
         myconfig = {
             'bootstrap.servers': kafka_servers,
-            'group_id': conf['group_id']}
+            'group.id': conf['group_id']}
 
         self.consumer = AlertConsumer(mytopics, myconfig, schema_path=schema_path)