From 8b58681c35d9b758e209c579a7b5f2fbf9f2bdbf Mon Sep 17 00:00:00 2001 From: philipp Date: Wed, 1 Apr 2026 01:07:10 +0200 Subject: [PATCH] Silence KafkaJS client logs --- src/bus/kafka/consumer.mjs | 8 ++++++-- src/bus/kafka/producer.mjs | 8 ++++++-- 2 files changed, 12 insertions(+), 4 deletions(-) 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 } = {}) {