From c198f30039d532619c05b1a60b7a3ecbc8325250 Mon Sep 17 00:00:00 2001 From: mauricio garcia suarez Date: Fri, 29 Jul 2022 16:47:29 +0200 Subject: [PATCH] quickwit test script updated --- kafka_sample.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kafka_sample.py b/kafka_sample.py index 47e9f8001..cba7869ab 100644 --- 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 )