A collection of Node-RED nodes for integrating with Cloudera's software distribution including Apache Hadoop. Includes nodes for producing and consuming Apache Kafka messages, as well as Apache Avro serialization and deserialization.

Pure JS Kafka Wire Protocol Library

Library for common kafka events

Adapter to connect with kafka broker

Custom Apache Kafka transport for Winston logger with TypeScript

基于 kafka-node 的一层封装。

This sub-repo contains tools for recovering the state of the destination sender redis servers from data stored in the kafka clearing topics

A middleware that validates Kafka topic's messages for Circe.

<h1 id="node-kafka-wrapper">Node-kafka-wrapper</h1> <p>Kafka-node-wrapper is a custom wrapper built around the <strong>npm</strong> module <strong>kafka-node</strong>. It tries to simplify the complexities of implementing the boiler-plate and helps in fo

Simple cli tool to reset offsets in Kafka using node-rdkafka

This is a fork with PR #169, check the original version. Apache Kafka 0.9 client for Node.JS

Apache Kafka producer and consumer nodes for Node-RED

hapijs-plugin for consuming and producing to a kafka queue

This is a small NextJS logger lib to work with KAFKA, will send logs to KAFKA and then we can collect logger in log service.

Apache Kafka event streaming integration for YAWL workflows with Avro serialization

Kafka Client Lib with segregated interfaces developed with clean architecture concepts by Superlógica Tecnologias S.A

kafka subscription and mysql crud service

NodeJS streaming clients (Consumer & Producer) for Apache Kafka.

A TypeScript library for consuming blockchain events through Kafka

AngularJS library to interact with Kafka end-points i.e. Rest APIs