From 1b32bafe44bebc2fadeb059bc9b52cf5585da85e Mon Sep 17 00:00:00 2001 From: wuaho Date: Thu, 21 Oct 2021 09:46:45 +0800 Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E8=AE=A2=E5=8D=95=E9=97=AE=E9=A2=98?= =?UTF-8?q?=E5=8A=A0=E6=97=A5=E5=BF=97=E8=B7=9F=E8=B8=AA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/app.py b/app.py index d04d3cf..5ed0ebb 100644 --- a/app.py +++ b/app.py @@ -52,7 +52,8 @@ class XProcess(Process): elif 'track' in type_: # continue if data['#event_name'] == 'pay': - self.log.info(data) + self.log.info(f'topid->{msg.topic} | partition->{msg.partition} | offset->{msg.offset} | data-> {data}') + obj = getattr(handler_event, type_) obj(data) elif type_ == settings.STOP_SIGNAL: