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]);
 		});