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 on node-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

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