改名

2020-10-09 17:18:50 +08:00
parent 415ad00a23
commit e72effee14
1 changed files with 1 additions and 1 deletions
@@ -46,7 +46,7 @@ class KafkaProviders extends Providers
 		if (!is_array($kafka['topics'])) {
 			throw new Exception('Add kafka topics must is array.');
 		}
-		$server->addProcess('kafka', [Kafka::class, false]);
+		$server->addProcess('kafka', Kafka::class);
 	}

 }