From a73ba003db298b1077bf1bdbdee84089db3ac96f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 9 Oct 2020 11:10:07 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Kafka/Producer/SyncProcess.php | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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.');