From 19c64b5801631a0c8381682db53806a859c8ce57 Mon Sep 17 00:00:00 2001
From: wuaho <wuaho@legu.cc>
Date: Tue, 26 Oct 2021 21:36:14 +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 | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/app.py b/app.py
index c725ea6..f83ba0e 100644
--- a/app.py
+++ b/app.py
@@ -69,14 +69,13 @@ class XProcess(Process):
                 self.log.info(type_)
                 if data.get('#time', 0) + 3600 < int(time.time()):
                     continue
-                kafka_client.commit()
-                kafka_client.close()
                 # 停止消费kafka
                 self.log.info(f'进程{self.partition} 等待90秒')
                 time.sleep(90)
                 self.log.info(f'进程{self.partition} 写入数据')
                 transmitter.run(kafka_client)
                 self.log.info(f'进程{self.partition} 结束')
+                kafka_client.close()
 
                 break
             elif type_ == 'test':