49 packages found
Authentication mechanism for AWS MSK IAM for kafkajs.
A no fuss rxjs wrapper for kafkajs, focused on ease of use.
Wrapper for KafkaJS library to be used with Strapi apps.
Fastify plugin that adds support for KafkaJS - a modern Apache Kafka client
open telemetry instrumentation for the `kafkajs` kafka client
Message Reprocessing for KafkaJS
Lightweight, tested, straight-forward wrapper around KafkaJS and Confluent's Schema Registry.
Plugin for kafkajs to buffer messages and send them in batches, inspired by node-rdkafka
Handle kafka non-blocking retries and dead letter topics for nestjs microservice
KafkaJS + unopinionated Avro encoding/decoding based on subject and version
Library to make using kafka for Nodejs
LZ4 compression codec for the KafkaJS library
Easily compose and manage your kafka resources in one place
NestJS CQRS event source module for KafkaJS
An API to generate mock payloads for @ovotech/castle using @ovotech/avro-mock-generator
The kafkajs adapter for socket.io
LZ4 compression codec for JS.