改为手动提交

2021-10-26 19:25:35 +08:00 · 2021-10-26 19:25:35 +08:00 · cf46c8b6d0
commit cf46c8b6d0
parent d639660839
1 changed files with 4 additions and 4 deletions
--- a/v2/transmitter.py
+++ b/v2/transmitter.py
@ -141,7 +141,7 @@ class Transmitter:
            except Exception as e:
                self.log.error(traceback.format_exc())
            buffer.clear()
-            try:
-                kafka_client.commit()
-            except Exception as e:
-                self.log.error(f'进程:{self.p}  error:{e}')
+            # try:
+            #     kafka_client.commit()
+            # except Exception as e:
+            #     self.log.error(f'进程:{self.p}  error:{e}')