Commit cb8b142e authored by lixiaofang's avatar lixiaofang

auto_vest

parent 26546f59
...@@ -111,7 +111,7 @@ def kafka_consum(topic_name=None): ...@@ -111,7 +111,7 @@ def kafka_consum(topic_name=None):
logging.info("push_time时间未到========================需要等待") logging.info("push_time时间未到========================需要等待")
save_data_to_kafka(card_info) save_data_to_kafka(card_info)
pass pass
print(datetime.datetime.now() - begin) print((datetime.datetime.now() - begin).seconds)
except: except:
consumser_obj.close() 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