as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
Mr·x
2020-10-09 11:07:15 +08:00
parent c4bde06838
commit 44f86005a8
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Producer/SyncProcess.php
+1
View File
@@ -113,6 +113,7 @@ class SyncProcess
$broker = \Kafka\Broker::getInstance(); $broker = \Kafka\Broker::getInstance();
foreach ($brokerHost as $host) { foreach ($brokerHost as $host) {
$socket = $broker->getMetaConnect($host, true); $socket = $broker->getMetaConnect($host, true);
var_dump($socket);
if ($socket) { if ($socket) {
$params = array(); $params = array();
$this->debug('Start sync metadata request params:' . json_encode($params)); $this->debug('Start sync metadata request params:' . json_encode($params));