node package manager


a node binding for librdkafka


Node.js binding for librdkafka. At this time, only the version of V8 included in node 0.10.x is supported.

Only connect and produce are implemented so far. consume will be forthcoming (but no immediate need)

Tested with kafka_2.8.0-0.8.0-beta1

From kafka folder

bin/ config/
bin/ config/
bin/ --zookeeper localhost:2181 --replica 1 --partition 1 --topic test
bin/ --zookeeper localhost:2181
bin/ --zookeeper localhost:2181 --topic test --from-beginning
bin/ --broker-list localhost:9092 --topic test
node-gyp configure
node-gyp build
node-gyp rebuild
var kafka = require("./lib/kafka");
var producer = new kafka.Producer({
  brokers: "localhost:9092",
  partition: 0,
  topic: "test"
producer.connect(function() {
  producer.send('message', 0, function(err) {
  }).on("sent", function(err) {
  }).on("delivery", function(err, length) {
  }).on("error", function(err) {
node example.js
node example2.js

See LICENSE, and LICENSE.* for dependencies