From 3b9ed0c98fb1631d49d8da2290246fe63966c6ec Mon Sep 17 00:00:00 2001
From: wuaho <wuaho@legu.cc>
Date: Thu, 21 Oct 2021 10:17:57 +0800
Subject: [PATCH] add unique id

---
 app.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/app.py b/app.py
index 61cd01a..61911d6 100644
--- 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