JSPM

A modern Apache Kafka client for node.js

Terminus integration provides readiness/liveness health checks for NestJS.

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.

Node.js bindings for librdkafka

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

Snappy codec for KafkaJS

open telemetry instrumentation for the `kafkajs` kafka client

Kafka module for Testcontainers

Node.js bindings for librdkafka

helper for consuming kubernetes service bindings

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

LZ4 compression codec for the KafkaJS library

message validator through asyncapi schema

Apache Kafka 0.9 client for Node.JS

A Pulumi package for creating and managing Kafka.

LZ4 streaming compression and decompression library for KafkaJS

Kafka CLI tool

Modern and performant client for Apache Kafka

A KafkaJS codec for ZStandard compression

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

Apache Kafka 0.9 client for Node.JS

A Backstage backend plugin that integrates towards Kafka

LZ4 compression codec for the KafkaJS library

Apollo graphql subscription over Kafka protocol

Mockingbird

A serverless offline plugin that enables AWS MSK events

A modern Apache Kafka client for node.js

CLI for Mockingibrd

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

Message validation package for YAML and JSON AsyncAPI documents.

A prometheus exporter for kafkajs

kafka-streams for Node.js

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

Fastify plugin that adds support for KafkaJS - a modern Apache Kafka client

Plugin for kafkajs to buffer messages and send them in batches, inspired by node-rdkafka

Simple event-streaming framework

A plugin to use common permissions of Kafka in Backstage

Pure JS Kafka LZ4 codec for kafkajs

This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.

Metrics package for KafkaJS

Fastify plugin to interact with Apache Kafka.

An kafkajs decorator with cooperative sticky assigner support

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

A plugin for the OgmaInterceptor to properly handle microservice requests from Kafka protocols

OpenTelemetry kafkajs automatic instrumentation package.

Kafka adapter for message-queue-toolkit

Interactive utility to analyze Kafka clusters health and configuration

[Patched 2.2.4 version] A modern Apache Kafka client for node.js

Opinionated Kafka Client for Microservices

Node.js bindings for librdkafka

Typed event SDK for Glow, powered by RabbitMQ and Zod.

Schema registry connector

AsyncAPI template for generating production-ready Rust servers

NodeJS wrapper for the Kafka REST Proxy

Nestjs wrapper for creation of standarized apps

**KafkaTS** is a Apache Kafka client library for Node.js. It provides both a low-level API for communicating directly with the Apache Kafka cluster and high-level APIs for publishing and subscribing to Kafka topics.

<div align="center">

Stream for kafkajs

TypeScript decorators for server-side applications with caching, tracking, and queue support

Node.js bindings for librdkafka

Midway Framework for kafka

Easy and flexible API mocking

This is the **x86_64-unknown-linux-musl** binary for `kafka-crab-js`

This is the **x86_64-unknown-linux-gnu** binary for `kafka-crab-js`

a split-able caching aggregation handler

Distributed Event Driven application development framework

Utility to easily handle message deserialization and parsing of Kafka events in AWS Lambda functions

CLI for Upstash resources.

Kafka producer and consumer service with message processing capabilities

An instance manager with observability for Node.js applications

Comprehensive New Relic instrumentation for NestJS applications - SQS, Kafka, HTTP/2, cron jobs and custom protocols

Backk - Node.js framework for creating secure cloud-native microservices for Kubernetes in Typescript

A configurable Kafka producer package for Node.js applications with NFL event examples and AWS MSK integration

A KafkaJS codec for ZStandard compression

Kafka Client Lib with segregated interfaces developed with clean architecture concepts by Superlógica Tecnologias S.A

Node.js bindings for librdkafka

Node-RED implements Kafka manager with associand associated .

Apollo graphql subscription over Kafka protocol

Factory universal para mensageria (RabbitMQ, Kafka, SQS) para sistemas distribuídos.

Helper for exposing node-rdkafka statistics through prometheus

PubSub for GraphQL Subscription based on Kafka.

A java asynchronous server for Dodex using quarkus

Helper functions to convert JSON objects to Avro according to your schema. And back to JSON.

Alyxstream is a library that simplify stream processing in Node.js. We use it in production to make real time logs analysis, errors detection, parallel job processing, using mainly Kafka as source and Cassandra and Redis as sinks. Although it's not perfec

This is the **aarch64-apple-darwin** binary for `kafka-crab-js`

Node-RED module for secure Apache Kafka publish/subscribe using the librdkafka C library

Workflow and State Machines for NestJS

Node.js bindings for librdkafka

This is the **aarch64-unknown-linux-musl** binary for `kafka-crab-js`

Node-RED node for Kafka message LZ4 compression

A robust npm package for handling dynamic topic creation, subscription, and management in multi-instance microservice architectures. Built on top of KafkaJS, this package provides a simplified interface for Kafka operations while maintaining full flexibil

This is the **x86_64-apple-darwin** binary for `kafka-crab-js`

A wrapper around node-rdkafka

CLI para generar proyectos rápidos con soporte para Express, TypeScript, GraphQL, HTML, Webhooks, Docker, OAuth, Redis, Kafka, y más.

Interface to node-rdkafka in Typescript

Opra Kafka package

This is the **aarch64-unknown-linux-gnu** binary for `kafka-crab-js`

Kafka rest client to produce json/binary messages

Lightweight event bus using Redis and Kafka

A robust and optimized JavaScript library for integrating Google's Teachable Machine models, supporting various image sources and providing efficient classification capabilities.

KafkaJS + unopinionated Avro encoding/decoding based on subject and version

kafka avro serialization

ksqldb-orm - Server-Side TypeScript ORM for ksqlDB with enterprise security extensions

A CLI package that wraps commander.js and mongo migration

RHOAS Kafka Instance Adminstration SDK

JokTec - Kafka Service

Print the express request log to console and save it to kafka when required, and even can send alram message when the response code greater than 500.

Helper for exposing node-rdkafka statistics through prometheus

A package to comunicate with a Kafka server and lets the user control the flow of message pipeline to control success and failure on message synchronization.

Confluent MCP Server

Multi-Broker Message Bus with Multi-Topic Support

Package for safe publishing messages into kafka topic with schema validation

A structured Kafka integration for NestJS inspired by BullMQ, offering decorators, modular configuration, and a scalable consumer/producer architecture.

Encode and decode kafka messages with Confluent Schema Registry (pure typescript implementation)

A kafka logger for winston

A transport for winston which logs to kafka.

Node.js bindings for librdkafka

Confluent Schema Registry serdes that use avro schemas.

Flexible and simple kafka transport for winston v3

Utilties to help manage a repository of versioned JSONSchemas.

kafka appender for log4js

This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.

A structured Kafka integration for NestJS inspired by BullMQ, offering decorators, modular configuration, and a scalable consumer/producer architecture.

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. Fixes Avro config issue

Kafka addon for AdonisJs

Kafka transport plugin for CloudEvents JS SDK

OAuthBearerProvider for kafkajs

log4js kafka appender

Rdkafka connector

json & avro schema registry

Enterprise-grade real-time data platform with ksqlDB, inspired by Supabase architecture

A fork of kafka-node Client for Apache Kafka v0.8.1+, v0.9.x, and v0.10.x

Kafka based webhooks system

Comprehensive OpenTelemetry instrumentation for NestJS applications - SQS, Kafka, HTTP/2, cron jobs and custom protocols

A NestJS module for integrating with Kafka using kafkajs

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.

Avro-based event schemas for TypeScript and Python services

An umbrella SDK for all other Upstash SDKs

CLI to scalable and a production-ready Express projects

LSK module for kafka.

Factory universal para mensageria (RabbitMQ, Kafka, SQS) para sistemas distribuídos.

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

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.

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.

winston as source to kafka connector

OpenTelemetry instrumentation for @platformatic/kafka

An API to generate mock payloads for @ovotech/castle using @ovotech/avro-mock-generator

Wrapper for KafkaJS library to be used with Strapi apps.

A Pulumi Provider for Kafka Connect, allows for:

Extended event publishing PubSub/Kafka package.

A different approach to integrating NestJs and Kafka

Official TypeScript SDK for IOSense platform APIs, providing seamless access to device management, user operations, authentication, and multi-protocol pub/sub messaging systems.

REST storage and service dispatcher

External adapters for SyntropyLog framework

KafkaJS connector

hiot-app middleware to bootstrap kafka

Kafka java client wrapper. Supports kafka version 0.8 and up

kafka-connect is a framework to move data via kafka

This is a simplified version of amqp javascript library

A node client for kafka, supporting upwards of v0.8 of the Kafka protocol, including commit/offset/fetch API. Does not require zookeeper integration

A KafkaJS codec for ZStandard compression using Bun's built-in zstd (forked from @kafkajs/zstd)

RHOAS Service Accounts SDK

kafka connect connector for Google BigTable

Queue integration module for CMMV with support for Redis, Kafka and RabbitMQ

A progressive Node.js package for building efficient and scalable server-side distributed queues with difficult relationships

Metrics package for KafkaJS with visualizer

MMS - Kafka Port for Javascript/Typescript

A robust, production-ready CLI for log monitoring with API/Kafka output, SMTP email alerts, disk-based queue with optional compression, dead-letter queue, metrics, and full config via file or environment variables. Recent improvements: SMTP alerting, disk

Lightweight, tested, straight-forward wrapper around KafkaJS and Confluent's Schema Registry.

A modern Apache Kafka client for node.js

Node-RED nodes of HighLevel Kafka Producer and Consumer

A wrapper around confluent kafka to send the messages securely.

NestJS extension library for Kafka

Node.js bindings for librdkafka

Node-Red module for Apache Kafka publish/subscribe using the Confluent librdkafka C library

Node.js bindings for librdkafka

Apache Kafka discovery, indexing, searches, storage, hooks and HTTP gateway

A CLI for xkite-core library for prototyping and testing with Apache Kafka

Core library for xkite application

kafka connect connector for Google BigQuery

Patch for Node-RED nodes of HighLevel Kafka Producer and Consumer

A Kafka wrapper around `kafkajs` that adds Kafka support to NestJs following the `Orchestrator and Explorer` pattern, with minimum boilerplate code needed.

## IMPORTANT :

Kafka for Node-RED

Node-Red module for Apache Kafka publish/subscribe using the Confluent REST Proxy

Ultimate command-line interface for Pulzar framework - scaffolding, development server, building, testing, code generation, health diagnostics, security auditing, and deployment tools for modern Node.js applications

A generic messaging abstraction library for NestJS that supports Kafka and RabbitMQ.

Additional features and extensions for BullMQ.

Kafka connect connector for Yildiz Graph Database

A modern Apache Kafka client for node.js

loopback client for integration with apache kafka

Kafka Confluent Schema Registry with only avro serializer. Only can operate with previously created schemas

Kafka Retrier Service

A Kafka client plugin for Hapi.js

Official DeltaStream sdk for Node.js

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.

A library to help implementation of kafka

A robust, easy to use kafka consumer

Kafka consumer for processing order creates and updates from USXPRESS

node-rdkafka event.stats callback that sends rdkafka statistics to statsd.

NodeJS dataverse Kafka Provider

Kafka transport layer for the orizuru package

RHOAS Kafka Management SDK

Kafka node reply is a function support service can send message as request and receive response from other consumer to complete request. Write base package kafka-node https://www.npmjs.com/package/kafka-node

kafka consumers and producers integrated with AWS Glue schema registry with RXJS for streaming

REST storage and service dispatcher

The kafka adapter for socket.io

Nodly is an interactive CLI for scaffolding modern Node.js/Express.js backend projects with instant setup for databases, mailers, queues, sockets, and more. Skip boilerplate and start building features fast.

A docker service for hosting kafka rest topic consumers

A SDK to help to build microservices for the dojot platform

Winston 3 transport for Kafka

A slim Promise wrapper around node-rdkafka classes

NestJS CQRS event source module for KafkaJS

An abstract interface to build data processing applications on a log-based architecture.

Apache Kafka 0.9 client for Node.JS without Snappy dependency

Avro schema registry client for Confluent's Schema Registry

Client for Apache Kafka v0.8.1+, v0.9.x, and v0.10.x

Python confluent kafka template for the AsyncAPI generator.

Node.js bindings for librdkafka - precompiled

Node.js bindings for librdkafka

clever-hinny与Redis交互js模块

A collection of Node-RED nodes for integrating with Cloudera's software distribution including Apache Hadoop. Includes nodes for producing and consuming Apache Kafka messages, as well as Apache Avro serialization and deserialization.

Node-Red module for Confluent Cloud

Next-generation Node.js framework for ultra-fast web applications with zero-reflection DI, GraphQL, WebSockets, events, and edge runtime support

clever-hinny数据库交互js模块

An Ajv instance wrapper for @kafkajs/confluent-schema-registry.

An adapter to connect a node.js application to the Test-bed's Common Information Space or Common Simulation Space.

The pub/sub library for node backed by AMQP (RabbitMQ) or just plain node!

Topic oriented, promise based, nodejs client for Kafka

Kafka plugin

Prozess is a kafka library for Node.js

A custom winston console logger for KafkaJS

Node.js bindings for librdkafka

Kafka adapter for HermesJS

Fastify package for consumer

Production-ready React Native library for MQTT messaging with integrated geospatial data management, PostGIS support, and Kafka streaming integration

kafka-connect connector for mysql,postgres and sqlite

Kafka transport for Winston

A cli for working with Apache Kafka development.

Keep track of your micro-service messages and dispatch tasks accordingly

Fastify package for producer

A node-rdkafka wrapper with extended features

A distributed, reliable, atomic, work queueing system that only requires redis as the backend.

Job orchestration made simple for Node.js message workflows

kafka as datasource-as-eventsource plugin for Godspeed Framework

```commandline # Install the npm package npm install @rickjms/microservices-common

beta package

Prozess is a kafka library for Node.js