leguadmin/to_ck
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

追踪错误

Browse Source
This commit is contained in:
wuaho 2021-10-27 09:56:38 +08:00
parent 5500e8386e
commit 9b59106f4d
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
v2/transmitter.py
View File

@ -140,6 +140,7 @@ class Transmitter:
self.__send(self.db_name, tb, [json.dumps(item) for item in data]) self.__send(self.db_name, tb, [json.dumps(item) for item in data])
except Exception as e: except Exception as e:
self.log.error(traceback.format_exc()) self.log.error(traceback.format_exc())
self.log.error(data)
buffer.clear() buffer.clear()
try: try:
kafka_client.commit() kafka_client.commit()