diff --git a/src/bus/kafka/consumer.mjs b/src/bus/kafka/consumer.mjs
index f1aaf4b..09b6829 100644
--- a/src/bus/kafka/consumer.mjs
+++ b/src/bus/kafka/consumer.mjs
@@ -1,8 +1,12 @@
-import { Kafka } from 'kafkajs';
+import { Kafka, logLevel } from 'kafkajs';
 import { serializeError } from '../../core/log.mjs';
 
 function createKafka({ brokers = ['127.0.0.1:9092'], clientId = 'unrip' } = {}) {
-  return new Kafka({ clientId, brokers });
+  return new Kafka({
+    clientId,
+    brokers,
+    logLevel: logLevel.NOTHING,
+  });
 }
 
 export async function createConsumer({ groupId, logger, ...options }) {
diff --git a/src/bus/kafka/producer.mjs b/src/bus/kafka/producer.mjs
index bf2b5ed..5405d12 100644
--- a/src/bus/kafka/producer.mjs
+++ b/src/bus/kafka/producer.mjs
@@ -1,8 +1,12 @@
-import { Kafka } from 'kafkajs';
+import { Kafka, logLevel } from 'kafkajs';
 import { serializeError } from '../../core/log.mjs';
 
 function createKafka({ brokers = ['127.0.0.1:9092'], clientId = 'unrip' } = {}) {
-  return new Kafka({ clientId, brokers });
+  return new Kafka({
+    clientId,
+    brokers,
+    logLevel: logLevel.NOTHING,
+  });
 }
 
 export async function createProducer({ logger, ...options } = {}) {