From dab225fc2c13c141356424093557e5c555677dd2 Mon Sep 17 00:00:00 2001
From: hebo <xiaobiao@jd.com>
Date: Tue, 13 Aug 2019 16:30:54 +0800
Subject: [PATCH] change check kafka script

---
 scripts/check_kafka.py | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/scripts/check_kafka.py b/scripts/check_kafka.py
index 36448d6..a46e809 100644
--- a/scripts/check_kafka.py
+++ b/scripts/check_kafka.py
@@ -1,4 +1,4 @@
-#  import json
+import json
 from kafka import KafkaConsumer, KafkaProducer
 
 
@@ -6,7 +6,7 @@ from kafka import KafkaConsumer, KafkaProducer
 kafka_server = '192.168.XX.XX:9091'
 
 group_id = 'sniffer'
-topic = 'ddl_sql_collector'
+topic = 'non_ddl_sql_collector'
 
 
 def check_consume():
@@ -21,8 +21,8 @@ def check_consume():
     consumer = KafkaConsumer(topic, **conf)
     print('ready to consume')
     for msg in consumer:
-        #  event = json.loads(bytes.decode(msg.value))
-        print(msg)
+        event = json.loads(bytes.decode(msg.value))
+        print(event)
 
 
 def check_produce():
@@ -45,8 +45,8 @@ def check_produce():
 
 
 def _real_main():
-    check_produce()
-    #  check_consume()
+    # check_produce()
+    check_consume()
 
 
 if __name__ == '__main__':