Socket
Book a DemoInstallSign in
Socket

kafkacat

Package Overview
Dependencies
Maintainers
1
Versions
3
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

kafkacat

node wrapper for kafkacat

latest
npmnpm
Version
0.0.3
Version published
Maintainers
1
Created
Source

status

Requirements

kafkacat binary needs to be available somewhere in your search path.

Quickly build using the bootsrap script: https://github.com/edenhill/kafkacat [1][2]

[1]: If you're using OSX, the librdkafka build fails when trying to build its examples. Some work arounds are suggested here.
[2]: Also, https://github.com/edenhill/kafkacat/issues/3

Usage

node-kafkacat turns the kafkacat C library into node streams. There is one difference between the consume stream and a typical readable stream, and that is the .end method which just kills the kakfacat process.

Refer to the tests for usage examples: https://github.com/Rafflecopter/node-kafkacat/blob/master/tests/index.js

The mapping of option keys passed to the stream constructor to kafkacat command-line arguments is documented in code here. Any extra settings as documented in kafkacat can be passed as well. node-kafkacat will take care of formatting them as -X key=val when calling kafkacat.

Keywords

kafka

FAQs

Package last updated on 14 Jan 2015

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts