JSPM

Easy and flexible API mocking

Node.js bindings for librdkafka

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`

a split-able caching aggregation handler

Distributed Event Driven application development framework

Kafka producer and consumer service with message processing capabilities

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

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

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

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.

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

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

Workflow and State Machines for NestJS

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

Node.js bindings for librdkafka

Node-RED node for Kafka message LZ4 compression

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

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

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

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

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

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

Helper for exposing node-rdkafka statistics through prometheus

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.

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.

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.

A transport for winston which logs to kafka.

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

A kafka logger for winston

Confluent Schema Registry serdes that use avro schemas.

Node.js bindings for librdkafka

Utilties to help manage a repository of versioned JSONSchemas.

kafka appender for log4js

MMS - Kafka Port for Javascript/Typescript

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.

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

Kafka addon for AdonisJs

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

log4js kafka appender

Kafka transport plugin for CloudEvents JS SDK

json & avro schema registry

Rdkafka connector

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

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

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

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.

OpenTelemetry instrumentation for @platformatic/kafka

winston as source to kafka connector

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

CLI to scalable and a production-ready Express projects

Wrapper for KafkaJS library to be used with Strapi apps.

A Pulumi Provider for Kafka Connect, allows for:

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.

REST storage and service dispatcher

External adapters for SyntropyLog framework

KafkaJS connector

hiot-app middleware to bootstrap kafka

kafka-connect is a framework to move data via kafka

Kafka java client wrapper. Supports kafka version 0.8 and up

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

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

kafka connect connector for Google BigTable

Metrics package for KafkaJS with visualizer

A different approach to integrating NestJs and Kafka

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

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.

Node.js bindings for librdkafka

An umbrella SDK for all other Upstash SDKs

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

Node.js bindings for librdkafka

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

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

Core library for xkite application

kafka connect connector for Google BigQuery

## IMPORTANT :

Kafka for Node-RED

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

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

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 Confluent Schema Registry with only avro serializer. Only can operate with previously created schemas

loopback client for integration with apache kafka

Kafka Retrier Service

A modern Apache Kafka client for node.js

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

RHOAS Kafka Management SDK

Kafka transport layer for the orizuru package

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

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

A SDK to help to build microservices for the dojot platform

Winston 3 transport for Kafka

A slim Promise wrapper around node-rdkafka classes

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

NestJS CQRS event source module for KafkaJS

Apache Kafka 0.9 client for Node.JS without Snappy dependency

Avro schema registry client for Confluent's Schema Registry

Node.js bindings for librdkafka

Node.js bindings for librdkafka - precompiled

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.

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

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

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.

Job orchestration made simple for Node.js message workflows

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

beta package

Prozess is a kafka library for Node.js

NodeJS Kafka Provider

Fastify package for producer

A node-rdkafka wrapper with extended features

Framework para el desarrollo de microservicios

Logging that supports different adapters base on your environment.

kafka-connect connector for prometheus

A Kafka package for automatic configuration

A module for producing records with Apache Kafka.

WebSockets based proxy for Kafka

Kafka consumer manager handles retries, offset issues and retries

Event Data Model Definition in Envoy

Shared Kafka client library for LoudTV microservices

A lightweight npm library for rapid and seamless setup of gRPC and Kafka clients and servers in Node.js. It includes one-command generation of build files from .proto files, with full TypeScript support for streamlined development.

kafka-connect connector for prometheus pushgateway

A NocoBase plugin for Apache Kafka integration, supporting message publishing, topic management, and event-driven workflows. Built for the DTU GreenHope project.

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

Kafka But Simpler

module for create kafka-node connection

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

Kafka based webhooks system

Reusable Kafka producer and consumer utilities using kafkajs.

An extensible typescript message bus with support for middlewares

RHOAS Kafka Management SDK

An express middleware to route requests to kafka

Queue based async message routing library

GFTD Schema Management CLI - Drizzle-like schema management for Kafka and ksqlDB

SDK for OpenTelemetry auto-instrumentation and OTLP export for Node.js apps.

Kafka java client wrapper. Supports kafka version 0.8 and up

A single solution for all your outgoing communications like: API calls[axios], Mailer(sms:2factor,email:AWS), MessageQueue[Kafka], Storage[AWS-S3,Cache(Redis),HDD(Local),SFTP] as a plugin interface. Just set some env properties, and start solving your pro

Stream processing library for Kafka in Node

RHOAS Service Registry Management SDK

Tool for generating serialized, encoded Kafka messages that can be passed into lambda to mimic an event received from an Event Source Mapping.

Kafka Dependency Plugin For Elevate Interface Service

Kafka module for NestJS

Confluent MCP Server

Abstraction on top of various cloud queuing systems

clever-hinny数据库交互js模块

Salesforce connector for node kafka connect

Kafka messaging for Pip.Services in Node.js / ES2017

A thin wrapper above Kafka REST

A Kafka-based signing and verification library using LMDB and Kafka

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

Kafka consumer module for lmdb

A module for encoding and decoding avro with Kafka.

This is a basic package to consume messages from kafka topic

Docker Infrastructure CLI

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 MessageHub Producer and Consumer

Avro Encoder Decoder

Node.js bindings for librdkafka

A Javascript wrapper for the Confluent Kafka REST API

Explorations for the log-backed in-memory cache we need in almost every service

kafka as datasource-as-eventsource plugin for Godspeed Framework

An interface for Kafka in Node

Apache Kafka to Google Pub/Sub Gateway, API controlled

NestJS package for producer

A SDK to help to build microservices for the dojot platform

Kafka Provider for AdonisJs

Node.js bindings for librdkafka

A module for consuming records with Apache Kafka.

The kafka producer and consumer client

Example Node.JS producer/consumer for Confluent Cloud

node logservice

Kafka Client http://incubator.apache.org/kafka/