改为手动提交

app.py

@@ -70,7 +70,7 @@ class XProcess(Process):
                 self.log.info(f'进程{self.partition} 等待90秒')
                 time.sleep(90)
                 self.log.info(f'进程{self.partition} 写入数据')
-                transmitter.run()
+                transmitter.run(kafka_client)
                 self.log.info(f'进程{self.partition} 结束')
 
                 break

settings.py.template

@@ -17,8 +17,9 @@ class Config:
         'bootstrap_servers': ["192.168.0.30:9092", "192.168.0.71:9092", "192.168.0.229:9092"],
         'value_deserializer': json.loads,
         'auto_offset_reset': 'earliest',
-        'enable_auto_commit': True,
-        'auto_commit_interval_ms': 10000,
+        'enable_auto_commit': False,
+        'max_poll_interval_ms': 3600000,
+        # 'auto_commit_interval_ms': 10000,
 
         # 每个游戏不一样
         # *************