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: