diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index c76d25ed..b80eba51 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -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) {