Kafka Packages

Apache Kafka topic and message anomaly detection with automated discovery

A slim Promise wrapper around node-rdkafka classes

Node-Red module for Apache Kafka publish/subscribe using the Confluent librdkafka C library

A simple helper for controlling when an offset is ready to be committed via node-rdkafka.

An adapter to connect a node.js application to the Test-bed's Common Information Space or Common Simulation Space.

Kafka java client wrapper. Supports kafka version 0.8 and up

A library to read Kafka messages populated by Debezium (Postgresql)

kafka message publisher, fallback appending messages to a file while kafka unavailable

Node-RED nodes of HighLevel MessageHub Producer and Consumer

A Kafka wrapper arount the kafka-node module, dummy proof adding reconnect management and consumer strict order processing

Interface to node-rdkafka in Typescript

A node client for kafka, supporting upwards of v0.8 of the Kafka protocol, including commit/offset/fetch API. Does not require zookeeper integration

A oeCloud mixin which publishes to a configured Kafka Queue during Model CRUD operations

light-webhook is a lightweight application for receiving webhooks from different sources, processing them as streams and publishing the results in sinks.

An extensible typescript message bus with support for middlewares

An abstract interface to build data processing applications on a log-based architecture.

Utility app for registering schemas in Confluent Schema Registry

Node.js bindings for librdkafka

Node streaming processor

Tools for kafka management in test environment