Commit f97b2184 authored by lixiaofang's avatar lixiaofang

add

parent a7c112fc
......@@ -140,7 +140,7 @@ def kafka_consum(topic_name=None):
str(msg.topic), str(msg.partition), str(msg.offset), str(msg.key)))
save_data_to_kafka(card_info)
else:
logging.info("此条数据已经被paas了:%s" % card_info)
logging.info("此条数据已经被paas了:%s" % card_info['card_id'])
logging.info("消费处理耗时:%f" % (time.time() - begin))
except:
consumser_obj.close()
......
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