From 3ff6ac1f5b6f71748e87e51c1ee2e19b6cb5ea5a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Mr=C2=B7x?= <as2252258@163.com>
Date: Mon, 12 Oct 2020 11:51:49 +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 | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/Kafka/Kafka.php b/Kafka/Kafka.php
index b3083bcf..08adbc8f 100644
--- a/Kafka/Kafka.php
+++ b/Kafka/Kafka.php
@@ -51,7 +51,10 @@ class Kafka extends \Snowflake\Process\Process
 		$this->channelListener();
 
 		$consumer = new Consumer();
-		$consumer->setLogger(new Logger());
+		$kafka = SConfig::get('kafka');
+		if ($kafka['debug'] ?? true) {
+			$consumer->setLogger(new Logger());
+		}
 		$consumer->start(function ($topic, $part, $message) {
 			$this->channel->push([$topic, $part, $message]);
 		});