From cf46c8b6d07096e27a59782ddbb1a356a17fe4a6 Mon Sep 17 00:00:00 2001 From: wuaho Date: Tue, 26 Oct 2021 19:25:35 +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 --- v2/transmitter.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/v2/transmitter.py b/v2/transmitter.py index 2e701d3..9f03419 100644 --- a/v2/transmitter.py +++ b/v2/transmitter.py @@ -141,7 +141,7 @@ class Transmitter: except Exception as e: self.log.error(traceback.format_exc()) buffer.clear() - try: - kafka_client.commit() - except Exception as e: - self.log.error(f'进程:{self.p} error:{e}') + # try: + # kafka_client.commit() + # except Exception as e: + # self.log.error(f'进程:{self.p} error:{e}')