diff --git a/Kafka/Consumer/Process.php b/Kafka/Consumer/Process.php index bb5ff167..aba56414 100644 --- a/Kafka/Consumer/Process.php +++ b/Kafka/Consumer/Process.php @@ -238,6 +238,7 @@ class Process $broker = \Kafka\Broker::getInstance(); foreach ($brokerHost as $host) { $socket = $broker->getMetaConnect($host); + var_dump($socket); if ($socket) { $params = \Kafka\ConsumerConfig::getInstance()->getTopics(); $this->debug('Start sync metadata request params:' . json_encode($params));