node-kafka

Node.js binding for librdkafka.

BUILD

Configure

node-gyp configure

Initial build

node-gyp build

Rebuild

node-gyp rebuild

EXAMPLE

var kafka = require("./lib/kafka");

var producer = new kafka.Producer({
  zookeeper: "localhost:2181",
  partition: 0,
  topic: "test"
});

producer.connect(function() {
  producer.send('message', function(err) {
    ...
  }).on("sent", function(err) {
    ...
  }).on("delivery", function(err, length) {
    ...
  }).on("error", function(err) {
    ...
  });
})

Please see examples directory for more. This project needs more testing and further direction.

TEST

node example.js
node example2.js

LICENSE

See LICENSE, and LICENSE.* for dependencies