改为手动提交

2021-10-26 21:14:30 +08:00 · 2021-10-26 21:14:30 +08:00 · e33a22d1d4
commit e33a22d1d4
parent 1d6854beff
1 changed files with 5 additions and 1 deletions
--- a/app.py
+++ b/app.py
@ -40,7 +40,11 @@ class XProcess(Process):
            type_ = data['#type']
            del data['#type']
            ts = int(time.time())
+            try:
                data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}'
+            except:
+                pass
+
            if msg.topic == 'debug':
                self.log.info(data)