myfork-node-rdkafka
Node.js bindings for librdkafka
Node.js bindings for librdkafka
A simple test module for log collection
The utils is Panda private
Encode and decode kafka messages with Confluent Schema Registry (pure typescript implementation)
Agnostic library for creating scalable and fault-tolerant workflows.
A no fuss rxjs wrapper for kafkajs, focused on ease of use.
rxjs + kafkajs
Package for safe publishing messages into kafka topic with schema validation
A serverless offline plugin that enables AWS MSK events
Confulent Kafka avro serializer with magic byte and schema id
Node Red Connector for both Apache Kafka and Azure Event Hub
Node Red Connector for both Apache Kafka and Azure Event Hub
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.
Node.js bindings for librdkafka
Node.js bindings for librdkafka
Node.js bindings for librdkafka
Node.js bindings for librdkafka
Node.js bindings for librdkafka