node-red-contrib-kafkajs-modified-greyorange2
This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.
This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.
This node can be used in order to produce and consume messages to Kafka. It is highly depends on 'kafkajs' library. Consists three nodes.
Library to make using kafka for Nodejs
Kafka integration with NestJS
OpenTelemetry automatic instrumentation package for kafkajs
KafkaJS integration with NestJS
An implementation for the Apollo PubSubEngine using the KafkaJS as backend.
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
Package for safe publishing messages into kafka topic with schema validation
A no fuss rxjs wrapper for kafkajs, focused on ease of use.
rxjs + kafkajs
Lightweight, tested, straight-forward wrapper around KafkaJS and Confluent's Schema Registry.
KafkaJS integration with NestJS, fork by @rob3000/nestjs-kafka:0.1.0
Exchange all common utilities includes in this package
Exchange all common utilities includes in this package
Custom partition assigner to handle multiple consumers under same group
Control batch size for kafkajs consumers
OpenTelemetry kafkajs automatic instrumentation package.