This commit is contained in:
2020-10-28 11:09:56 +08:00
parent 8b7f1247e6
commit e7a171dd68
+1 -1
View File
@@ -148,7 +148,7 @@ class Kafka extends \Snowflake\Process\Process
});
$conf->set('group.id', $kafka['groupId']);
// $conf->set('metadata.broker.list', '127.0.0.1:2080');
$conf->set('metadata.broker.list', '172.26.221.220:2080');
$conf->set('metadata.broker.list', '172.26.221.220');
$conf->set('socket.timeout.ms', 30000);
if (function_exists('pcntl_sigprocmask')) {