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