diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index 364c870f..7563075a 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -127,7 +127,7 @@ class Kafka implements CustomProcess $container = Snowflake::app()->get('kafka-container'); $handler = $container->getConsumer($topic); - var_dump($topic, $message, $handler); + var_dump($container); if (!empty($handler)) { /** @var ConsumerInterface $data */ $data = new $handler();