From 0dbf4ebc08ab4e60e9fc2b898cc6a213bf0d810f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 20 Aug 2021 10:19:05 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Kafka/Kafka.php | 4 +--- Server/ServerManager.php | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) 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()) {