kafkajs for egg.

Dockerized Kafka and Zookeeper with KafkaJS client sample application.

Microservices which use kafka as message broker

Typesafe & reactive Kafka Subjects made with Typescript, KafkaJS and RxJS

A simple project to learn concepts of kafka using a lib kafkajs

KafkaJS adapter for socket.io

A sample Kafka consumer and producer written in Typescript using Kafkajs.

kafka是一个分布式发布订阅消息系统，这里使用canal作为Producer，将mysql中的数据放入到kafka消息队列中，再通过kafkajs来消费数据

OAuth bearer authentication example using Red Hat OpenShift Streams for Apache Kafka and KafkaJS

A really basic test is to check the time spent to produce and consume messages using node-rdkafka and kafkajs.

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

A simple project that accepts car ID and entry time as inputs and returns total parking time and total parking charge as output.

🚀 Kafka example: Fastify API written in typescript interacts with python processor

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

Snappy codec for KafkaJS

Kafka non-blocking retry topic for nestjs microservice.

Kafka broker to collect currency rates with nodejs

Functional prototype to test kafka technology with asynchronous microservice

a sample example of nestjs micro services with Kafka