quickwit test script updated

2022-07-29 16:47:29 +02:00 · 2022-07-29 16:47:29 +02:00 · c198f30039
commit c198f30039
parent 125e5289be
1 changed files with 1 additions and 1 deletions
--- a/kafka_sample.py
+++ b/kafka_sample.py
@ -56,7 +56,7 @@ def create_consumer():
    consumer = KafkaConsumer(#security_protocol="SSL",
                             bootstrap_servers=os.environ['KAFKA_SERVER_2'],
                                               # os.environ['KAFKA_SERVER_1']],
-                             group_id=f"quickwit_connector",
+                             group_id=f"quickwit_connector2",
                             auto_offset_reset="earliest",
                             enable_auto_commit=False
                             )