From fb42eded2c059d47508e148af886685e16cc5afe Mon Sep 17 00:00:00 2001 From: mauricio garcia suarez Date: Wed, 13 Jul 2022 13:36:08 +0200 Subject: [PATCH] fixed minor issue consumer.py --- ee/connectors/consumer.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ee/connectors/consumer.py b/ee/connectors/consumer.py index f65633f7d..acf55f2d5 100644 --- a/ee/connectors/consumer.py +++ b/ee/connectors/consumer.py @@ -30,7 +30,7 @@ def main(): codec = MessageCodec() consumer = KafkaConsumer(security_protocol="SSL", - bootstrap_servers=os.environ['KAFKA_SERVER_2'], + bootstrap_servers=[os.environ['KAFKA_SERVER_2'], os.environ['KAFKA_SERVER_1']], group_id=f"my_test3_connector_{DATABASE}", auto_offset_reset="earliest",