From 5b0467944bec2a915f0e975091902f791798c0fb Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sun, 11 Apr 2021 18:11:49 +0800 Subject: [PATCH] modify --- Kafka/TaskContainer.php | 1 + 1 file changed, 1 insertion(+) 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; }