leguadmin/to_ck
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

gmhdgdt,gmhdtt

Browse Source
This commit is contained in:
wuaho 2021-07-28 20:37:33 +08:00
parent f96f5da864
commit 1dc9f42471
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
v2/consumer.py
View File

@ -17,8 +17,8 @@ def create_consumer(partition=-1):
# print(msg) # print(msg)
topic = msg.topic topic = msg.topic
val = msg.value val = msg.value
# if val.get('properties',{}).get('owner_name') not in ('gmhdgdt', 'gmhdtt'): if val.get('properties',{}).get('owner_name') not in ('gmhdgdt', 'gmhdtt'):
# continue continue
yield topic, val yield topic, val
return consumer return consumer