diff --git a/app.py b/app.py
index f83ba0e..3a638be 100644
--- a/app.py
+++ b/app.py
@@ -75,6 +75,7 @@ class XProcess(Process):
                 self.log.info(f'进程{self.partition} 写入数据')
                 transmitter.run(kafka_client)
                 self.log.info(f'进程{self.partition} 结束')
+                kafka_client.commit()
                 kafka_client.close()
 
                 break