改名

2021-08-05 16:37:05 +08:00
parent def8aa7cdc
commit 2402ead3e7
1 changed files with 1 additions and 0 deletions
@@ -27,6 +27,7 @@ class KafkaProvider extends BaseObject
        if (isset($this->_topics[$topic])) {
            return;
        }
+        var_dump($topic, $handler);
        $this->_topics[$topic] = $handler::class;
    }