Kafka Packages

Client for Apache Kafka v0.9.x, v0.10.x and v0.11.x

A modern Apache Kafka client for node.js

Terminus integration provides readiness/liveness health checks for NestJS.

Node.js bindings for librdkafka

ConfluentSchemaRegistry is a library that makes it easier to interact with the Confluent schema registry, it provides convenient methods to encode, decode and register new schemas using the Apache Avro serialization format.

Apache Kafka 0.9 client for Node.JS

Snappy codec for KafkaJS

Apache Kafka 0.9 client for Node.JS

Confluent Schema Registry implementation in javascript to easily serialize and deserialize kafka messages

NodeJS wrapper for the Kafka REST Proxy

The pub/sub library for node backed by Redis, MongoDB, AMQP (RabbitMQ), ZeroMQ, Kafka, MQTT (Mosquitto) or just plain node!

This JS-script calculates the partition based on a key and the amount of partitions for a JS Kafka producer in way consistent to the default Java Kafka client

Node.js module for connecting to the Kafka REST interface of IBM Message Hub.

LZ4 compression codec for the KafkaJS library

kafka avro serialization

Simple in-memory job queue

Node.js kafka client, consumer, producer polite out of the box

message validator through asyncapi schema

The pub/sub library for node backed by Redis, MongoDB, AMQP (RabbitMQ), ZeroMQ, Kafka, MQTT (Mosquitto) or just plain node!

A Pulumi package for creating and managing Kafka.