js extensions for the open-telemetry project

An open-source GUI for managing and monitoring Kafka cluster health

KafkaPeek is an open-source application designed to help developers visualize, monitor, and stay up-to-date on their Kafka deployments

Apollo graphql subscriptions using kafkajs

Salary Payment Project

A package that enables applications to publish, consume and process high volumes of records streams in a fast and durable way.

Advanced Raidfinder for Granblue Fantasy. 【グランブルファンタジー】のTwitter救援をまとめ

Provides a KafkaJS-compatible handler for processing messages that facilitates publishing to delayed-retry or dead-letter topics

Tickets sales application for FIFA World Cup Qatar 22. It is a web application where users can purchase tickets for matches along with admin dashboard to view states about sold tickets. The application is built using event driven architecture along with security best practices and TDD

MicroServices with NestJS and a Gateway-Api + KAFKA + MongoDB

Basic Kafka client that does publish subscribe and runs as a Windows application

Kafka non-blocking retry topic for nestjs microservice.

Util for kafkajs to buffer messages and send them in batches, inspired by node-rdkafka

正在為大數據所苦嗎？帶你了解 Kafka 這個分布式消息串流平台，以及它能解決什麼問題！

kafkajs snappy codec library ready for typescript

Snappy codec for KafkaJS

Fastify plugin that adds support for KafkaJS - a modern Apache Kafka client

📨 Effectful Kafka

透過 Jaeger with OpenTelemetry 追蹤 Kafka 資料傳遞路徑與運行狀況（使用 W3CTraceContextPropagator 自定義 Parent & Child 關聯性）

Example Node with KafkaJS