var winston = require('winston');
require('winston-kafka-connect');
 
winston.add(new winston.transports.WinstonKafkaTransport({
    level: "info",
    format: customFormat,
    meta: {},
    kafkaClient:{
    	kafkaHost: "localhost:9092 [,localhost:9093, localhost:9094]",
    	clientId: "winston-kafka-logger"
    }
    topic: "winston-logs",
    name: 'WinstonKafkaLogger',
    timestamp: function() {return Date.now()},
    formatter: JSON.stringify
});