Skip to content

V
vest
Commit 6406e4dc authored by lixiaofang's avatar lixiaofang
Browse files
Options

add

parent c9991d10
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
moment/views/consum.py
View file @ 6406e4dc
...@@ -39,7 +39,7 @@ def kafka_consum(topic_name=None): ...@@ -39,7 +39,7 @@ def kafka_consum(topic_name=None):
card_info = json.loads(str(msg.value, encoding="utf8")) card_info = json.loads(str(msg.value, encoding="utf8"))
if card_info['card_id'] in [719961, 718880, 717122, 720913]: if card_info['card_id'] in [719961, 718880, 717122, 720913]:
pass logging.info("删除重复数据:%s" % card_info['card_id'])
if card_info['card_type'] == "auto_vest": if card_info['card_type'] == "auto_vest":
###在这里去判断一下当前的partition和offset是否已经消费过了 如果已经消费了需要直接去掉数据 ###在这里去判断一下当前的partition和offset是否已经消费过了 如果已经消费了需要直接去掉数据
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment