diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index c6423beb..3c43ab7f 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -127,6 +127,7 @@ class Kafka implements CustomProcess
 
 				$setting = $server->setting['worker_num'];
 
+				var_dump($topic, $message);
 				$container = Snowflake::app()->get('kafka-container');
 				$handler = $container->getConsumer($topic);