diff --git a/app.py b/app.py index 61911d6..d50ea77 100644 --- a/app.py +++ b/app.py @@ -41,6 +41,8 @@ class XProcess(Process): del data['#type'] ts = int(time.time()) data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}' + if msg.topic == 'debug': + self.log.info(data) if 'user' in type_: # continue