add

moment/views/consum.py

@@ -45,7 +45,7 @@ def kafka_consum(topic_name=None):
                         #                                                 partition=msg.partition)
                         ##在这里先判断当前的数据是否已经存在，存在的话直接PaaS，不存在的话再做下边的处理
                         bol_consum = judge_data_have_in_redis(card_info)
-                        bol_consum = True
+                        # bol_consum = True
                         if bol_consum:
                             logging.info("消费到新数据了[%s,%s,%s,%s],get card_info:%s" % (
                                 str(msg.topic), str(msg.partition), str(msg.offset), str(msg.key), card_info))