The most advanced Kafka Client.
- 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-node
and 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
- check out node-kafka-streams for a stream processing kafka api
- check out 🔥 node-kafka-connect for a easy datastore <-> kafka transfer
Can be found here
npm install --save sinek
const {
NConsumer,
NProducer
} = require("sinek");
- We suggest using the native clients NConsumer & NProducer implementations, if possible.
- Native Client (NConsumer & NProducer)
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)
- 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