diff --git a/single_process.py b/single_process.py
index 10ac4ed..32b47ff 100644
--- a/single_process.py
+++ b/single_process.py
@@ -23,16 +23,18 @@ def run():
     handler_event = HandlerEvent(db_client, settings.GAME, ipsearch)
     handler_user = HandlerUser(db_client, settings.GAME)
     transmitter = Transmitter(db_client, settings.GAME, sketch, logger, lock, event_attr)
-    transmitter.add_source(handler_event, 10000, 60)
-    transmitter.add_source(handler_user, 1000, 60)
+    transmitter.add_source(handler_event, 10000, 10)
+    transmitter.add_source(handler_user, 1000, 10)
     last_ts = int(time.time())
-    consumer = create_consumer(-1)
+    consumer, kafka_client = create_consumer(-1)
 
     for topic, msg in consumer():
         # print(msg)
         type_ = msg['#type']
-        if msg['#app_id']!='e903ab24ad8f4bfca8a3ce7e122cd102':
-            print(msg)
+        if msg['#event_name'] != 'pay':
+            continue
+        print(msg)
+
         del msg['#type']
         ts = int(time.time())