diff --git a/app.py b/app.py
index 33ef189..c725ea6 100644
--- a/app.py
+++ b/app.py
@@ -40,7 +40,11 @@ class XProcess(Process):
             type_ = data['#type']
             del data['#type']
             ts = int(time.time())
-            data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}'
+            try:
+                data['properties']['unique_id'] = f'{msg.topic}-{msg.partition}-{msg.offset}'
+            except:
+                pass
+
             if msg.topic == 'debug':
                 self.log.info(data)