jan/openreplay
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixed minor issue consumer.py

Browse source
This commit is contained in:
mauricio garcia suarez 2022-07-13 13:36:08 +02:00
parent 2e8f582bf7
commit fb42eded2c
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
ee/connectors/consumer.py
View file

@ -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",