@nimley/kafka-nimley v0.1.0

Kafka Nimley

A simple wrapper around kafkajs

Installation

npm install kafka-nimley --save

Usage

const kafka = require("kafka-nimley");

const client = await kafka.connect();

// Send a message to a topic `test`:
client.producer.send({
  topic: "test",
  messages: [
    {
      key: "test",
      value: "data",
      headers: {
        "key": "value"
      }
    }
  ]
});