diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index 9670bcd1..5679cbfb 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -41,6 +41,7 @@ class Kafka extends \Snowflake\Process\Process $waite = new WaitGroup(); $kafkaServers = SConfig::get('kafka.servers'); + var_dump($kafkaServers); foreach ($kafkaServers as $kafkaServer) { $waite->add(); go(function () use ($kafkaServer, $waite) {