kafka-logger

    7.1.0 • Public • Published

    kafka-logger

    A kafka transport for winston

    Usage

    var winston = require('winston');
     
    winston.transports.Kafka = require('kafka-logger');
     
    winston.add(winston.transports.Kafka, options);

    The Kafka transport currently uses node-kafka-rest-client. The Kafka transport takes the following options:

    • topic - The Kafka topic to publish to.
    • proxyHost - The Kafka REST Proxy host to publish to.
    • proxyPort - The Kafka REST Proxy port to publish to.
    • properties - Top-level properties that should be added to the JSON object published to the kafka topic; useful if multiple processes use the same topic
    • dateFormats - An object of date formats to use; keys are the names of the keys the format should be added to, values are the names of the formats (useful for cross-language usage of the logs to reduce transforms on the consumers). These formats are: epoch (time in sec since Jan 1, 1970), jsepoch (time in ms since Jan 1, 1970), pyepoch (time in sec since Jan 1, 1970, but floating point with ms resolution), iso (ISO datestring format)

    Install

    npm install winston kafka-logger

    Testing

    npm test

    There is a kafka.js that will talk to kafka if it is running and just gets skipped if its not running.

    To run kafka run zookeeper & kafka with npm run start-zk and npm run start-kafka

    MIT Licenced

    Install

    npm i kafka-logger

    DownloadsWeekly Downloads

    536

    Version

    7.1.0

    License

    MIT

    Unpacked Size

    31.7 kB

    Total Files

    13

    Last publish

    Collaborators

    • raynos
    • uber