改为手动提交

2021-10-26 18:29:23 +08:00 · 2021-10-26 18:29:23 +08:00 · d639660839
commit d639660839
parent e6331341a5
1 changed files with 1 additions and 1 deletions
--- a/v2/transmitter.py
+++ b/v2/transmitter.py
@ -144,4 +144,4 @@ class Transmitter:
            try:
                kafka_client.commit()
            except Exception as e:
-                self.log.error(e)
+                self.log.error(f'进程:{self.p}  error:{e}')