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 17:40:17 +08:00
parent 6029e2cb7f
commit 2e345482aa
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Kafka/Consumer/Process.php
+1
View File
@@ -238,6 +238,7 @@ class Process
$broker = \Kafka\Broker::getInstance(); $broker = \Kafka\Broker::getInstance();
foreach ($brokerHost as $host) { foreach ($brokerHost as $host) {
$socket = $broker->getMetaConnect($host); $socket = $broker->getMetaConnect($host);
var_dump($socket);
if ($socket) { if ($socket) {
$params = \Kafka\ConsumerConfig::getInstance()->getTopics(); $params = \Kafka\ConsumerConfig::getInstance()->getTopics();
$this->debug('Start sync metadata request params:' . json_encode($params)); $this->debug('Start sync metadata request params:' . json_encode($params));