Package Exports

sinek

This package does not declare an exports field, so the exports above have been automatically detected and optimized by JSPM instead. If any package subpath is missing, it is recommended to post an issue to the original package (sinek) to support the "exports" field. If that is not possible, create a JSPM override to customize the exports field for this package.

Readme

node-sinek

kafka client(s) polite out of the box

make it about them, not about you

Simon Sinek

Info

promise based api
core builds kafka-node module (checkout for options & tweaking)
uses ConsumerGroup(s) means your kafka needs to be > 0.9.x ( - 0.10.2+)
check out :goberserk: node-kafka-streams for a stream processing kafka api
check out 🔥 node-kafka-connect for a easy datastore <-> kafka transfer

Offers

easy api
no worries backpressure service (dont fry your database)
auto-commit / manual drain commit in backpressure-mode (dont loose data)
a lot of pitfalls are automatically taken care of
provides a drain once for consumers (that reads a whole topic and fires an event)
provides easy partition spreading, keyed messages and json formats for producers

Install

npm install --save sinek

Usage

const {Kafka, Drainer, Publisher, PartitionDrainer, Consumer, Producer} = require("sinek");

Docs

If you just want a Kafka Client (Producer / Consumer) that works well and ships batteries included, just take a look at these two and their setup example:
Consumer & Producer

sinek