kafkajs-snappy
Snappy codec for KafkaJS
Snappy codec for KafkaJS
LZ4 compression codec for the KafkaJS library
open telemetry instrumentation for the `kafkajs` kafka client
Easily compose and manage your kafka resources in one place
KafkaJS + unopinionated Avro encoding/decoding based on subject and version
open telemetry instrumentation for the `kafkajs` kafka client
An API to generate mock payloads for @ovotech/castle using @ovotech/avro-mock-generator
This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.
The kafkajs adapter for socket.io
A KafkaJS codec for ZStandard compression
Stream for kafkajs
Typesafe & reactive Kafka Subjects made with Typescript and RxJS
Stomp Kafka Bridge package connects stomp with kafka by pushing messages from stomp to kafka and supports config driven topics
apache-kafkajs plugin for egg
Stream processing library for Kafka in Node
KafkaJS integration with NestJS
KafkaJS integration with NestJS
A comprehensive prototyping, testing, and monitoring toolset built for Apache Kafka.
A CLI for xkite-core library for prototyping and testing with Apache Kafka
Core library for xkite application