diff --git a/app.py b/app.py
index 5ed0ebb..3f19a36 100644
--- 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