diff --git a/Kafka/TaskContainer.php b/Kafka/TaskContainer.php index ac1de270..eb884053 100644 --- a/Kafka/TaskContainer.php +++ b/Kafka/TaskContainer.php @@ -38,7 +38,7 @@ class TaskContainer extends BaseObject public function process($topic, Struct $struct) { $handler = $this->_topics[$topic] ?? null; - var_dump($handler, $struct); + var_dump($this->_topics, $topic, $struct); if (empty($handler)) { return; }