From 5500e8386e75b903e46ce08e4d266a696bd8455a Mon Sep 17 00:00:00 2001
From: wuaho <wuaho@legu.cc>
Date: Tue, 26 Oct 2021 21:36:57 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E4=B8=BA=E6=89=8B=E5=8A=A8=E6=8F=90?=
 =?UTF-8?q?=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app.py | 1 +
 1 file changed, 1 insertion(+)

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