去掉多余的判断

moment/views/consum.py

@@ -36,9 +36,8 @@ def kafka_consum(topic_name=None):
         while True:
             begin = time.time()
             msg_dict = consumser_obj.poll(timeout_ms=100, max_records=30)
-            for msg_key in msg_dict:
-                consume_msg = msg_dict[msg_key]
-                for msg in consume_msg:
+            for msg_value in msg_dict.values():
+                for msg in msg_value:
                     card_info = json.loads(str(msg.value, encoding="utf8"))
                     if card_info['card_type'] == "auto_vest":
                         ###在这里去判断一下当前的partition和offset是否已经消费过了  如果已经消费了需要直接去掉数据