
RocksDB, Redis, Postgres.Īsync (Promises) and sync stream operators e.g. 100 Javascript, with no native addons required. No Dependencies Committed to staying lean and dependency free. KafkaJS has no affiliation with and is not endorsed by The Apache Software Foundation. Overwriteable local-storage solution allows for any kind of datastore e.g. KAFKA is a registered trademark of The Apache Software Foundation and has been licensed for use by KafkaJS. Yet they still feel natural in this api :squirrel: Consumer groups must have unique group ids within the cluster, from a kafka broker perspective. When a consumer fails the load is automatically distributed to other members of the group. The lib also comes with a few window operations that are more similar to Apache Flink, Consumer groups allow a group of machines or processes to coordinate access to a list of topics, distributing the load among the consumers.

This article provides general background on Node.js in reactive systems, then takes you step-by-step through a reactive service built with Node.js and Apache Kafka. Kafka-streams 🐙 equivalent for nodejs ✨ 🐢 🚀 ✨īuild on super fast 🔥 observables using most.js 🤘Ĭomes with js and native Kafka client, for more performance and SSL, SASL and Kerberos features Although the Reactive Manifesto is language-agnostic and framework-agnostic, Node.js is an excellent framework for carrying out its principles. I am aiming for the easiest api access possible checkout the word count example

#NODEJS KAFKA INSTALL#
You will have to manually install node-rdkafka alongside kafka-streams.
