diff --git a/v2/transmitter.py b/v2/transmitter.py
index 2e701d3..9f03419 100644
--- 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}')