This commit is contained in:
2021-05-08 16:28:50 +08:00
parent c43ce9270c
commit 0592f2b50f
4 changed files with 48 additions and 12 deletions
+2 -2
View File
@@ -173,8 +173,8 @@ class Kafka extends \Snowflake\Process\Process
$conf->set('metadata.broker.list', $kafka['brokers']);
$conf->set('socket.timeout.ms', '30000');
logger()->debug('kafka listen groupId ' . $kafka['groupId']);
logger()->debug('kafka listen brokers ' . $kafka['brokers']);
debug('kafka listen groupId ' . $kafka['groupId']);
debug('kafka listen brokers ' . $kafka['brokers']);
if (function_exists('pcntl_sigprocmask')) {
pcntl_sigprocmask(SIG_BLOCK, array(SIGIO));