改名

2020-10-28 11:53:26 +08:00
parent 3b5c588eeb
commit 4a2bcfdde7
1 changed files with 1 additions and 1 deletions
@@ -56,9 +56,9 @@ class Kafka extends \Snowflake\Process\Process
 	public function onHandler(Process $process)
 	{
 		$this->channelListener();
-		$kafkaServers = SConfig::get('kafka');

 		$waite = new WaitGroup();
+		$kafkaServers = SConfig::get('kafka.servers');
 		foreach ($kafkaServers as $kafkaServer) {
 			$waite->add();
 			go(function () use ($kafkaServer, $waite) {