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