add unique id

2021-10-21 10:13:21 +08:00 · 2021-10-21 10:13:21 +08:00 · 4176aae943
commit 4176aae943
parent debadeb774
1 changed files with 1 additions and 1 deletions
--- a/app.py
+++ b/app.py
@ -40,7 +40,7 @@ class XProcess(Process):
            type_ = data['#type']
            del data['#type']
            ts = int(time.time())
-            data['unique_id'] = f'{msg.partition}-{msg.offset}'
+            data['properties']['unique_id'] = f'{msg.partition}-{msg.offset}'

            if 'user' in type_:
                # continue