diff --git a/Kafka/Producer/SyncProcess.php b/Kafka/Producer/SyncProcess.php
index e9b2e0fe..3c7f142f 100644
--- a/Kafka/Producer/SyncProcess.php
+++ b/Kafka/Producer/SyncProcess.php
@@ -113,15 +113,12 @@ 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));
                 $requestData = \Kafka\Protocol::encode(\Kafka\Protocol::METADATA_REQUEST, $params);
                 $socket->write($requestData);
-                $dataLen = \Kafka\Protocol\Protocol::unpack(\Kafka\Protocol\Protocol::BIT_B32, $socket->read(4));
-                $data = $socket->read($dataLen);
-                $correlationId = \Kafka\Protocol\Protocol::unpack(\Kafka\Protocol\Protocol::BIT_B32, substr($data, 0, 4));
+                $data = $socket->read(\Kafka\Protocol\Protocol::unpack(\Kafka\Protocol\Protocol::BIT_B32, $socket->read(4)));
                 $result = \Kafka\Protocol::decode(\Kafka\Protocol::METADATA_REQUEST, substr($data, 4));
                 if (!isset($result['brokers']) || !isset($result['topics'])) {
                     throw new \Kafka\Exception('Get metadata is fail, brokers or topics is null.');