add unique id

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

            if 'user' in type_:
                # continue