const { Kafka }         = require('kafkajs');
    const KafkaJSLogCreator = require('kafkajs-logger');

    const kafka = new Kafka({
        clientId  : 'my-app',
        brokers   : ['localhost:9092'],
        logCreator: KafkaJSLogCreator
    });