aa

moment/views/consum.py

@@ -40,6 +40,7 @@ def kafka_consum(topic_name=None):
 
                     if card_info['card_id'] in [719961, 718880, 717122, 720913]:
                         logging.info("删除重复数据:%s" % card_info['card_id'])
+                        pass
 
                     if card_info['card_type'] == "auto_vest":
                         ###在这里去判断一下当前的partition和offset是否已经消费过了  如果已经消费了需要直接去掉数据