diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php index 938f56b5..3265aae8 100644 --- a/Kafka/Kafka.php +++ b/Kafka/Kafka.php @@ -14,7 +14,6 @@ use RdKafka\Exception; use RdKafka\KafkaConsumer; use RdKafka\TopicConf; use Server\Abstracts\CustomProcess; -use Swoole\Coroutine; use Swoole\Process; use Throwable; @@ -152,8 +151,7 @@ class Kafka extends CustomProcess $conf->set('metadata.broker.list', $kafka['brokers']); $conf->set('socket.timeout.ms', '30000'); - debug('kafka listen groupId ' . $kafka['groupId']); - debug('kafka listen brokers ' . $kafka['brokers']); + info('kafka listen groupId ' . $kafka['groupId'] . ', brokers ' . $kafka['brokers']); if (function_exists('pcntl_sigprocmask')) { pcntl_sigprocmask(SIG_BLOCK, array(SIGIO)); diff --git a/Server/ServerManager.php b/Server/ServerManager.php index 723045d0..1410b5d6 100644 --- a/Server/ServerManager.php +++ b/Server/ServerManager.php @@ -143,7 +143,7 @@ class ServerManager } $name = $customProcess->getProcessName($soloProcess); - debug(sprintf("Process %s start.", $name)); + info(sprintf("Process %s start.", $name)); $system = sprintf('%s.process[%d]', Config::get('id', 'system-service'), $soloProcess->pid); if (Kiri::getPlatform()->isLinux()) {