wuhao/xlegudata_consumer
1
0
Fork 0
Code Issues Pull Requests Releases 1 Wiki Activity

update

Browse Source
This commit is contained in:
wuhao 2020-11-13 20:02:49 +08:00
parent 6de17f4722
commit ab3b196cba
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
main.py
View File

@ -31,7 +31,7 @@ def main():
sasl_plain_username=conf['sasl_plain_username'], sasl_plain_username=conf['sasl_plain_username'],
sasl_plain_password=conf['sasl_plain_password'], sasl_plain_password=conf['sasl_plain_password'],
value_deserializer=json.loads) value_deserializer=json.loads)
consumer.subscribe((conf['topic_name'],)) consumer.subscribe(conf['topic_name'])
for msg in consumer: for msg in consumer:
st = time.time() * 1000 st = time.time() * 1000
key = msg.key key = msg.key

4
setting.py
View File

@ -13,8 +13,8 @@ class Config:
'sasl_plain_username': 'legu666666', 'sasl_plain_username': 'legu666666',
'sasl_plain_password': '5EINbjyI', 'sasl_plain_password': '5EINbjyI',
'bootstrap_servers': ["39.104.71.242:9093", "39.104.71.78:9093", "39.104.67.122:9093"], 'bootstrap_servers': ["39.104.71.242:9093", "39.104.71.78:9093", "39.104.67.122:9093"],
'topic_name': 'legu_geshouccs', 'topic_name': os.environ.get('topic_name').split(','),
'consumer_id': 'geshouccs_consumer' 'consumer_id': os.environ.get('consumer_id')
} }
local_mongo_uri = os.environ["local_mongo_uri"] local_mongo_uri = os.environ["local_mongo_uri"]