kafkajs-logger A custom winston console logger for KafkaJS Usage const { Kafka } = require('kafkajs'); const KafkaJSLogCreator = require('kafkajs-logger'); const kafka = new Kafka({ clientId : 'my-app', brokers : ['localhost:9092'], logCreator: KafkaJSLogCreator }); Console Output