改名

2021-08-13 15:19:07 +08:00
parent 3198d66753
commit 62145acb8c
11 changed files with 13 additions and 14 deletions
@@ -27,7 +27,7 @@ class KafkaProvider extends BaseObject
        if (isset($this->_topics[$topic])) {
            return;
        }
-        $this->_topics[$topic] = $handler::class;
+        $this->_topics[$topic] = $handler;
    }