diff --git a/Kafka/KafkaProvider.php b/Kafka/KafkaProvider.php index b15f0737..eba7882e 100644 --- a/Kafka/KafkaProvider.php +++ b/Kafka/KafkaProvider.php @@ -27,6 +27,7 @@ class KafkaProvider extends BaseObject if (isset($this->_topics[$topic])) { return; } + var_dump($topic, $handler); $this->_topics[$topic] = $handler::class; }