High Level Node.js Kafka Client
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-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
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 sinek
Usage
Usage - JS Client (based on kafka.js)
const JSConsumer JSProducer } = ; const jsProducerConfig = clientId: "my-app" brokers: "kafka1:9092" async { const topic = "my-topic"; const producer = jsProducerConfig; const consumer = topic jsConsumerConfig; producer; consumer; await consumer; // consume from a topic. consumer; // Produce messages to a topic. await producer; producer};
Further Docs
- Best-practice example
- SSL example
- SASL+SSL example
- Alpine based docker example
- Debian based docker example
make it about them, not about you
- Simon Sinek