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
Stream processing library for Kafka in Node
apache-kafkajs plugin for egg
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