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
High Level Node.js Kafka Client - sinek
The most advanced Kafka Client.
Features
- easy promise based API
- a lot of Kafka pitfalls already taken care of
- backpressure and stream consume modes
- secure committing in backpressure (1:n, batch) mode
- plain Javascript implementation based on
kafka-nodeand a super fast native implementation based onnode-rdkafka - SSL, SASL & Kerberos support
- auto reconnects
- auto partition recognition and deterministic spreading for producers
- intelligent health-checks and analytic events for consumers and producers
You might also like
- check out :goberserk: node-kafka-streams for a stream processing kafka api
- check out 🔥 node-kafka-connect for a easy datastore <-> kafka transfer
Latest Changes
Can be found here
Install
npm install --save sinekUsage - Native Client
const {
NConsumer,
NProducer
} = require("sinek");- We suggest using the native clients NConsumer & NProducer implementations, if possible.
- Native Client (NConsumer & NProducer)
Usage - Javascript Client
const {
Consumer,
Producer
} = require("sinek");- If you cannot use the native clients, you can still use sinek's fallbacks JS implementations
- Kafka Client (Consumer & Producer)
Docs
- SSL example
- SASL example with the Native Client
- Alpine based docker example
- Debian based docker example
- The older client implementations:
- Publisher
- Drainer
- PartitionDrainer
- Hints & Help
make it about them, not about you
- Simon Sinek