改为手动提交

2021-10-26 21:36:57 +08:00 · 2021-10-26 21:36:57 +08:00 · 5500e8386e
commit 5500e8386e
parent 19c64b5801
1 changed files with 1 additions and 0 deletions
--- 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