A Kafka wrapper using kafkajs for producing, consuming, and managing Kafka topics dynamically

Enhanced Kafka nodes for n8n with manual offset management and timeout handling

Node.js bindings for librdkafka with Avro schema serialization.

simple kafka listener in the style of an express app

Kafka broadcast extension for LevelTwo

A simplified, reusable NestJS Kafka events package with retry and DLQ support

TDI MC - Kafka Service

Kafka for NestJS

kafka as datasource-as-eventsource plugin for Godspeed Framework

Moleculer Gateway service with kafka transporter

Package for safe publishing messages into kafka topic with schema validation

Simple stream-based kafka listener

This is a Node module to streamline Kafka integration for Node services. It's intended to provide a common and heavily-abstracted Kafka client to use for consuming messages from the Kafka cluster.

Utilities for CloudScaile extensions: env validation, logging, Kafka, and platform HTTP client

Apache Kafka 0.9 client for Node.JS with updates for lodash vulnerability

Reusable, robust Kafka consumer package with dynamic handler mapping, consumer pools and multi-topic support

error handling and concurrency handling for kafka-node HighLevelConsumer (0.8)

Adapter providing reactive access to Apache Kafka from the Skip runtime

Job executor for Kafka

Serialize/deserialize kafka-node streams with avro data, using confluent schema-registry to hold the schemas