改名

Kafka/Kafka.php

@@ -127,7 +127,7 @@ class Kafka implements CustomProcess
 
                 $setting = $server->setting['worker_num'];
 
-                /** @var TaskProvider $container */
+                /** @var KafkaProvider $container */
                 $container = Snowflake::app()->get('kafka-container');
                 $handler = $container->getConsumer($topic);
 

Kafka/KafkaProvider.php

@@ -8,10 +8,10 @@ use Snowflake\Abstracts\BaseObject;
 
 
 /**
- * Class TaskProvider
+ * Class KafkaProvider
  * @package Kafka
  */
-class TaskProvider extends BaseObject
+class KafkaProvider extends BaseObject
 {