Winston-kafka-connect NPM

winston-kafka-connect

Simple kafka transport for winston (winston as source to kafka connector)

Install

npm install winston winston-kafka-connect --save

Usage

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
});