diff --git a/Kafka/Producer/SyncProcess.php b/Kafka/Producer/SyncProcess.php index 333a9d7e..e9b2e0fe 100644 --- a/Kafka/Producer/SyncProcess.php +++ b/Kafka/Producer/SyncProcess.php @@ -113,6 +113,7 @@ class SyncProcess $broker = \Kafka\Broker::getInstance(); foreach ($brokerHost as $host) { $socket = $broker->getMetaConnect($host, true); + var_dump($socket); if ($socket) { $params = array(); $this->debug('Start sync metadata request params:' . json_encode($params));