diff --git a/v2/consumer.py b/v2/consumer.py
index 8e3cfcd..32cde0c 100644
--- a/v2/consumer.py
+++ b/v2/consumer.py
@@ -18,6 +18,8 @@ def create_consumer(partition=-1):
             # print(msg)
             topic = msg.topic
             val = msg.value
+            if val.get('properties',{}).get('owner_name') not in ('gmhdgdt', 'gmhdtt'):
+                continue
             yield topic, val
 
     return consumer, c