add unique id

2021-10-21 10:17:57 +08:00 · 2021-10-21 10:17:57 +08:00 · 3b9ed0c98f
commit 3b9ed0c98f
parent 4176aae943
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['properties']['unique_id'] = f'{msg.partition}-{msg.offset}'
+            data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}'

            if 'user' in type_:
                # continue