ConfluentSchemaRegistry is a library that makes it easier to interact with the Confluent schema registry, it provides convenient methods to encode, decode and register new schemas using the Apache Avro serialization format.

Terminal UI for AWS MSK Kafka with IAM auth, multi-environment switching, and live topic and consumer-group inspection

Connector drivers — Redis List / Stream / Kafka / Webhook (input + output + probing)

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.

Kafka consumer lag root cause analyzer

Kafka Android Client for React Native

Apache Kafka adapter for BabelQueue — canonical-envelope publisher and a URN-routed, process-then-commit consumer (SDK-owned retry topics + DLQ).

A nest-js kafka module

Adapter to connect with kafka broker

Kafka provider with retry and DLQ support for Clamed applications

基于 kafka-node 的一层封装。

Custom Apache Kafka transport for Winston logger with TypeScript

Library for common kafka events

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

<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

Kafka for NestJS

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

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

Apache Kafka event streaming integration for YAWL workflows with Avro serialization

kafka subscription and mysql crud service