From 1dc9f424710e4a18c320259c5abb75ce62089ff6 Mon Sep 17 00:00:00 2001
From: wuaho <wuaho@legu.cc>
Date: Wed, 28 Jul 2021 20:37:33 +0800
Subject: [PATCH] gmhdgdt,gmhdtt

---
 v2/consumer.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/v2/consumer.py b/v2/consumer.py
index ff12e4f..747cef4 100644
--- a/v2/consumer.py
+++ b/v2/consumer.py
@@ -17,8 +17,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
+            if val.get('properties',{}).get('owner_name') not in ('gmhdgdt', 'gmhdtt'):
+                continue
             yield topic, val
 
     return consumer