JSPM

Terminus integration provides readiness/liveness health checks for NestJS.

A modern Apache Kafka client 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.

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

Node.js bindings for librdkafka

Kafka module for Testcontainers

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

Apollo graphql subscription over Kafka protocol

A serverless offline plugin that enables AWS MSK events

LZ4 compression codec for the KafkaJS library

A modern Apache Kafka client for node.js

Mockingbird

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

CLI for Mockingibrd

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

kafka-streams for Node.js

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

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

Pure JS Kafka LZ4 codec for kafkajs

A plugin to use common permissions of Kafka in Backstage

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

Simple event-streaming framework

Metrics package for KafkaJS

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

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.

OpenTelemetry kafkajs automatic instrumentation package.

Kafka adapter for message-queue-toolkit

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

Interactive utility to analyze Kafka clusters health and configuration

Opinionated Kafka Client for Microservices

Node.js bindings for librdkafka

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

AsyncAPI template for generating production-ready Rust servers

NodeJS wrapper for the Kafka REST Proxy

Midway Framework for kafka

Nestjs wrapper for creation of standarized apps

Schema registry connector

**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

Easy and flexible API mocking

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

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

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

Node.js bindings for librdkafka

Distributed Event Driven application development framework

a split-able caching aggregation handler

An instance manager with observability for Node.js applications

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

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

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

CLI for Upstash resources.

A KafkaJS codec for ZStandard compression

Opra Kafka package

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

Helper for exposing node-rdkafka statistics through prometheus

A java asynchronous server for Dodex using quarkus

PubSub for GraphQL Subscription based on Kafka.

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

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

Kafka producer and consumer service with message processing capabilities

A wrapper around node-rdkafka

Workflow and State Machines for NestJS

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

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

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

Node.js bindings for librdkafka

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`

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

Interface to node-rdkafka in Typescript

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

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.

Kafka rest client to produce json/binary messages

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

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

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

kafka avro serialization

A CLI package that wraps commander.js and mongo migration

JokTec - Kafka Service

RHOAS Kafka Instance Adminstration SDK

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.

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.

Multi-Broker Message Bus with Multi-Topic Support

Confluent MCP Server

Utilties to help manage a repository of versioned JSONSchemas.

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.

A transport for winston which logs to kafka.

Confluent Schema Registry serdes that use avro schemas.

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

A kafka logger for winston

MMS - Kafka Port for Javascript/Typescript

Node.js bindings for librdkafka

kafka appender for log4js

Flexible and simple kafka transport for winston v3

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

Helper for exposing node-rdkafka statistics through prometheus

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

Kafka addon for AdonisJs

RHOAS Kafka Management SDK

json & avro schema registry

log4js kafka appender

Rdkafka connector

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

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

Kafka transport plugin for CloudEvents JS SDK

OAuthBearerProvider for kafkajs

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

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

A NestJS module for integrating with Kafka using kafkajs

Avro-based event schemas for TypeScript and Python services

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.

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!

LSK module for kafka.

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

CLI to scalable and a production-ready Express projects

Wrapper for KafkaJS library to be used with Strapi apps.

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

Extended event publishing PubSub/Kafka package.

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

External adapters for SyntropyLog framework

A Pulumi Provider for Kafka Connect, allows for:

REST storage and service dispatcher

KafkaJS connector

hiot-app middleware to bootstrap kafka

kafka-connect is a framework to move data via kafka

This is a simplified version of amqp javascript library

Kafka java client wrapper. Supports kafka version 0.8 and up

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

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

kafka connect connector for Google BigTable

A different approach to integrating NestJs and Kafka

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

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

A modern Apache Kafka client 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.

Node-RED nodes of HighLevel Kafka Producer and Consumer

NestJS extension library for Kafka

A wrapper around confluent kafka to send the messages securely.

An umbrella SDK for all other Upstash SDKs

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

Core library for xkite application

kafka connect connector for Google BigQuery

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

A slim Promise wrapper around node-rdkafka classes

Kafka for Node-RED

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

## IMPORTANT :

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.

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

Kafka Retrier Service

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

loopback client for integration with apache kafka

A modern Apache Kafka client for node.js

A Kafka client plugin for Hapi.js

Official DeltaStream sdk for Node.js

Kafka plugin

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 robust, easy to use kafka consumer

A library to help implementation of kafka

Kafka consumer for processing order creates and updates from USXPRESS

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

Kafka transport layer for the orizuru package

REST storage and service dispatcher

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

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.

The kafka adapter for socket.io

A docker service for hosting kafka rest topic consumers

NodeJS dataverse Kafka Provider

A SDK to help to build microservices for the dojot platform

Winston 3 transport for Kafka

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

NestJS CQRS event source module for KafkaJS

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.js bindings for librdkafka - precompiled

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

Python confluent kafka template for the AsyncAPI generator.

Node-Red module for Confluent Cloud

clever-hinny数据库交互js模块

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

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

A custom winston console logger for KafkaJS

Prozess is a kafka library for Node.js

Topic oriented, promise based, nodejs client for Kafka

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!

Node.js bindings for librdkafka

Kafka adapter for HermesJS

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

Fastify package for consumer

kafka-connect connector for mysql,postgres and sqlite

A cli for working with Apache Kafka development.

Kafka transport for Winston

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

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

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

beta package

NodeJS Kafka Provider

Prozess is a kafka library for Node.js

Shared Kafka client library for LoudTV microservices

Fastify package for producer

A node-rdkafka wrapper with extended features

Framework para el desarrollo de microservicios