GitHub topics: kafkajs
jalorenz/nestjs-kafkajs-module
Importable module for Nest.js to use in Kafka.js in your application
Language: TypeScript - Size: 49.8 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 0 - Forks: 0

christiangalsterer/kafkajs-prometheus-exporter
A prometheus exporter exposing metrics for KafkaJS
Language: TypeScript - Size: 3.08 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 5 - Forks: 4

NiladriChatterje/gamingstore
e-commerce platform with functional payment gateway integration and scalable backend through multiprocessing, multithreading and kafka
Language: TypeScript - Size: 1.82 MB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 2 - Forks: 0

tsmx/kafkajs-file-consumer
File-consumer project for the "Using Apache Kafka for transferring files" tutorial
Language: JavaScript - Size: 12.7 KB - Last synced at: 12 days ago - Pushed at: 26 days ago - Stars: 0 - Forks: 0

tsmx/kafkajs-file-producer
File-producer project for the "Using Apache Kafka for transferring files" tutorial
Language: JavaScript - Size: 2.49 MB - Last synced at: 12 days ago - Pushed at: 26 days ago - Stars: 0 - Forks: 0

nielchaudhary/kafkajs-notifications
notification system using kafkajs.
Language: TypeScript - Size: 0 Bytes - Last synced at: 28 days ago - Pushed at: 28 days ago - Stars: 0 - Forks: 0

IMRANDIL/Next_JS_Turbo_Repo_Scaleable_chat_APP
a turbo repo using nextjs and http server with socket.io and redis on cloud, a scaleable chat app with pub/sub model and kafka and kafkajs and postgres all in the cloud and prisma orm
Language: JavaScript - Size: 78.5 MB - Last synced at: about 5 hours ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

floydspace/effect-kafka
📨 Effectful Kafka
Language: TypeScript - Size: 656 KB - Last synced at: 8 days ago - Pushed at: 19 days ago - Stars: 14 - Forks: 2

fahadhossain24/kafka-node-ts
Kafka+express+typescript
Language: TypeScript - Size: 0 Bytes - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

tulios/kafkajs-snappy
Snappy codec for KafkaJS
Language: JavaScript - Size: 119 KB - Last synced at: 17 days ago - Pushed at: over 1 year ago - Stars: 7 - Forks: 5

shutterstock/kafkajs-async-retry 📦
Provides a KafkaJS-compatible handler for processing messages that facilitates publishing to delayed-retry or dead-letter topics
Language: TypeScript - Size: 1020 KB - Last synced at: 8 days ago - Pushed at: 4 months ago - Stars: 16 - Forks: 2

oslabs-beta/kalibrate
An open-source GUI for managing and monitoring Kafka cluster health
Language: TypeScript - Size: 6.37 MB - Last synced at: 24 days ago - Pushed at: almost 2 years ago - Stars: 59 - Forks: 3

aspecto-io/opentelemetry-ext-js 📦
js extensions for the open-telemetry project
Language: TypeScript - Size: 954 KB - Last synced at: 4 days ago - Pushed at: about 1 year ago - Stars: 171 - Forks: 40

chetanghadiya007/kafka_zookeeper_nodejs
Scalable Application Using Kafka, Zookeeper, and Node.js
Language: JavaScript - Size: 2.93 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

19EB/microservices-base-kafka
Nodejs project on microservices using Apache Kafka as messaging queue
Language: TypeScript - Size: 55.7 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 5 - Forks: 1

NiladriChatterje/kafka-binance-tracker
monitoring 6 cryptos with 3 consumers from same group using Kafkajs. Follow @binance/connector-typescript
Language: TypeScript - Size: 0 Bytes - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0

halovina/nodejs-kafka
Learn Realtime Communication: Kafka and Node.js Step-by-Step Tutorial
Language: JavaScript - Size: 1.95 KB - Last synced at: 2 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

codeterrayt/Scalable-Chat-App
A robust and scalable chat web application built on a modern tech stack. This project leverages Express.js, Socket.IO, Redis, Kafka, ZooKeeper, and MongoDB for backend infrastructure, while utilizing Svelte for a responsive and dynamic frontend.
Language: JavaScript - Size: 102 KB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 6 - Forks: 0

dean9703111/kafka-demo
正在為大數據所苦嗎?帶你了解 Kafka 這個分布式消息串流平台,以及它能解決什麼問題!
Language: JavaScript - Size: 49.8 MB - Last synced at: 19 days ago - Pushed at: 10 months ago - Stars: 11 - Forks: 0

kffl/fastify-kafkajs
Fastify plugin that adds support for KafkaJS - a modern Apache Kafka client
Language: JavaScript - Size: 20.5 KB - Last synced at: 11 days ago - Pushed at: over 1 year ago - Stars: 7 - Forks: 0

fenil3357/kafkajs-demo
A simple demo project to understand the working of kafka with expressjs using kafkajs.
Language: JavaScript - Size: 11.7 KB - Last synced at: 2 months ago - Pushed at: 6 months ago - Stars: 0 - Forks: 0

irfnd/irfandi-betest
Implementation for technical test Code.id
Language: TypeScript - Size: 157 KB - Last synced at: about 1 month ago - Pushed at: 7 months ago - Stars: 0 - Forks: 0

dean9703111/kafka-jaeger-demo
透過 Jaeger with OpenTelemetry 追蹤 Kafka 資料傳遞路徑與運行狀況(使用 W3CTraceContextPropagator 自定義 Parent & Child 關聯性)
Language: JavaScript - Size: 907 KB - Last synced at: 19 days ago - Pushed at: over 2 years ago - Stars: 4 - Forks: 0

senghor/express-kafka
How to get started with Kafka, NodeJS & ExpressJS
Language: JavaScript - Size: 19.5 KB - Last synced at: 4 months ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0

oslabs-beta/KafkaPeek
KafkaPeek is an open-source application designed to help developers visualize, monitor, and stay up-to-date on their Kafka deployments
Language: JavaScript - Size: 3.91 MB - Last synced at: 24 days ago - Pushed at: over 2 years ago - Stars: 50 - Forks: 4

imbenrabi/Event-Driven-Architecture
Managed monorepo, that implements event driven flow using tRPC and Kafka.
Language: TypeScript - Size: 189 KB - Last synced at: 10 days ago - Pushed at: 8 months ago - Stars: 1 - Forks: 0

albertojuanL/kafkajs-buffer
Util for kafkajs to buffer messages and send them in batches, inspired by node-rdkafka
Language: TypeScript - Size: 146 KB - Last synced at: 5 days ago - Pushed at: about 1 year ago - Stars: 11 - Forks: 1

aldenvallestero/node-js-kafka
This is a beginner friendly repository that demonstrates how to set up kafka with Node JS server participants.
Language: JavaScript - Size: 406 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

KedarKK1/apache-kafka-nodejs-projects
Some of my apache-kafka-nodejs projects made with docker-compose.yml
Language: JavaScript - Size: 1.46 MB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

celalaygar/Nodejs-apache-kafka-and-rabbitmq
Nodejs RabbitMQ and Nodejs Apache Kafka with Docker
Language: JavaScript - Size: 7.81 KB - Last synced at: 3 months ago - Pushed at: almost 2 years ago - Stars: 1 - Forks: 2

rschand-dev/nms-microservice
A fully fledged Notification Management System developed using JavaScript, Node.js, Express.js, Bull.js, Redis, & Apache Kafka. Uses Microservices Architecture.🌹
Language: JavaScript - Size: 92.8 KB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 1 - Forks: 0

wesleysbmartins/node_kafka
Implementação de integração entre uma aplicação Node TS com Kafka, criando seus tópicos, producers e consumers.
Language: TypeScript - Size: 15.6 KB - Last synced at: 2 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

muhammedt1207/e-commerce-clean-microservice
Mini E-Commerce Backend is a TypeScript-based backend for a mini e-commerce application, built using a microservice architecture and clean architecture principles. It features inter-service communication via KafkaJS, ensuring efficient and scalable message handling.
Language: TypeScript - Size: 12.8 MB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

pirumu/kafka-retry
Kafka non-blocking retry topic for nestjs microservice.
Language: TypeScript - Size: 75.2 KB - Last synced at: 27 days ago - Pushed at: about 3 years ago - Stars: 12 - Forks: 3

CodeMaster17/kafka-nodejs
Kafka with Nodejs
Language: JavaScript - Size: 1.95 KB - Last synced at: 2 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0

AyemunHossain/nodejs-kafka-boilerplate
🚀This GitHub repository provides a comprehensive implementation of Apache Kafka integration with Node.js. With this repository, you can seamlessly interact with Apache Kafka by leveraging the power of Node.js. Key features include the ability to create dynamic topics on-the-fly and automatic subscription to dynamically created topics by consumers.
Language: JavaScript - Size: 51.8 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

tomasAlabes/graphql-kafkajs-subscriptions
Apollo graphql subscriptions using kafkajs
Language: TypeScript - Size: 997 KB - Last synced at: 8 days ago - Pushed at: 9 months ago - Stars: 24 - Forks: 7

mdmuhtasimfuadfahim/kafka-pub-sub
A package that enables applications to publish, consume and process high volumes of records streams in a fast and durable way.
Language: JavaScript - Size: 261 KB - Last synced at: 20 days ago - Pushed at: over 1 year ago - Stars: 17 - Forks: 4

declerckt/kafkajs-snappy-typescript
kafkajs snappy codec library ready for typescript
Language: TypeScript - Size: 11.7 KB - Last synced at: 8 days ago - Pushed at: about 1 year ago - Stars: 7 - Forks: 1

yassinejouao/kafka-js-socket
This repository provide a solution for integrating Kafka, a distributed streaming platform, with WebSocket, a communication protocol, using JavaScript. is currently under development.
Language: Python - Size: 32.2 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0

epsagon/epsagon-node-frameworks 📦
Automated tracing library for Node.js frameworks ⚡️
Language: JavaScript - Size: 1.5 MB - Last synced at: about 1 year ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 8

buka-inc/npm.nestjs-kafka
NestJS module supporting multiple connections implemented using KafkaJS
Language: TypeScript - Size: 33.2 KB - Last synced at: 2 days ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

devleandrodias/challenge-backend-crocs
This Node.js application is designed to read streaming data from various data sources in the form of IP numbers.
Language: TypeScript - Size: 220 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

polyseam/deno-kafka-demo
integrating Deno and KafkaJS for educational purposes
Language: TypeScript - Size: 15.6 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0

matthew-nguyen-20032023/salary-hero-backend
Salary Payment Project
Language: TypeScript - Size: 307 KB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 18 - Forks: 4

choewy/nestjs-kafka
NestJS Kafka Module
Language: TypeScript - Size: 159 KB - Last synced at: 12 days ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

cebrailinanc/nest-project
Language: TypeScript - Size: 212 KB - Last synced at: 3 months ago - Pushed at: about 1 year ago - Stars: 0 - Forks: 0

vinodnextcoder/nodejs-kafkajs
Language: JavaScript - Size: 4.88 KB - Last synced at: 4 days ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

open-source-ts/kafka-message-bus
Kafka Message Bus is a KafkaJS wrapper enhancing its functionality with deadletter topic support and handlers, improving Kafka stream reliability by managing failed message processing. 🚀
Language: TypeScript - Size: 90.8 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

007tickooayush/inv-upload
Basic file handling approaches using http Requests, using nodejs, fastAPI, mongoDB, and mysql.
Language: JavaScript - Size: 26.4 KB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

FaissalElfid/Game_Simulator_Backend
MicroServices with NestJS and a Gateway-Api + KAFKA + MongoDB
Language: TypeScript - Size: 4.1 MB - Last synced at: about 2 months ago - Pushed at: over 3 years ago - Stars: 13 - Forks: 0

Am0stafa/Tickets-Sales-System
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
Language: JavaScript - Size: 143 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 10 - Forks: 6

ayoub3bidi/kafka-on-the-shore
Playing around with kafka.
Language: Python - Size: 12.7 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

codezilla322/kafka-demo-projects
Demo projects written in Node.js, Python, Go for Apache Kafka using kraft
Language: Go - Size: 92.8 KB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

kennethnwc/turorepo-kafka-cilent
Shared Kafka-client package Strongly Typed(kind of)
Language: TypeScript - Size: 134 KB - Last synced at: 3 months ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

daneshzaki/kokpit
Basic Kafka client that does publish subscribe and runs as a Windows application
Language: HTML - Size: 125 KB - Last synced at: 6 months ago - Pushed at: over 3 years ago - Stars: 12 - Forks: 3

williamkoller/kafka-node
Example Node with KafkaJS
Language: JavaScript - Size: 22.5 KB - Last synced at: 29 days ago - Pushed at: about 2 years ago - Stars: 4 - Forks: 1

raviagheda/kafka-quick-start
A Kafka get started typescript app with producer ( as server ) and consumer
Language: TypeScript - Size: 11.7 KB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

WGLabz/kafka-explorer
A kafka client to produce and consume events/messages. A handy utility to test your apps and Kafka cluster.
Language: Vue - Size: 7.02 MB - Last synced at: almost 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

cchen26/Kafka-Revive
Lightweight Message Re-processing Wrapper Library for KafkaJs
Language: TypeScript - Size: 74.2 KB - Last synced at: 18 days ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

Wajahat-Husain/kakfa-docker
Code and files for an Apache Kafka project with a Kafka producer, consumer, cluster setup, and Docker instructions.
Language: JavaScript - Size: 25.4 KB - Last synced at: 2 months ago - Pushed at: almost 2 years ago - Stars: 1 - Forks: 0

AposLaz/Blog-microservices
This is a small microservice application for Blog
Language: JavaScript - Size: 2.26 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 0 - Forks: 0

MirzaMuhammadBaig/Get-Pool-Feeds-From-different-dexs
This is our first project from antematter in which I am fetching feeds from different dexs of solana & ethereum and then that's data store in kafka with partitions.
Language: JavaScript - Size: 2.51 MB - Last synced at: almost 2 years ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 0

NthMetal/gbraidfinder
Advanced Raidfinder for Granblue Fantasy. 【グランブルファンタジー】のTwitter救援をまとめ
Language: TypeScript - Size: 14 MB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 20 - Forks: 2

Allan-Nava/KafkaJS-WS
A modern Apache Kafka client for node.js
Language: TypeScript - Size: 125 KB - Last synced at: 3 days ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 2

larbibaraka/nestjs-Kafka-microservices
a sample example of nestjs micro services with Kafka
Language: TypeScript - Size: 98.6 KB - Last synced at: 2 months ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 0

rodrigobarbosa12/simple-kafka-example
Basic example of kafka
Language: TypeScript - Size: 13.7 KB - Last synced at: about 2 months ago - Pushed at: almost 3 years ago - Stars: 2 - Forks: 0

brunosm16/node-kafka-certificate
Implementation of Microservices with NodeJS and Kafka. Main API and a Microservice to generate an certification.
Language: TypeScript - Size: 81.1 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

Keyur996/node-email-service-kafka
email-Service
Language: TypeScript - Size: 13.7 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0

nodeshift-archived/kfk-token-example 📦
OAuth bearer authentication example using Red Hat OpenShift Streams for Apache Kafka and KafkaJS
Language: JavaScript - Size: 2.93 KB - Last synced at: about 1 year ago - Pushed at: almost 4 years ago - Stars: 0 - Forks: 1

nodeshift-archived/kfk-perf-test-case 📦
A really basic test is to check the time spent to produce and consume messages using node-rdkafka and kafkajs.
Language: JavaScript - Size: 6.84 KB - Last synced at: about 1 year ago - Pushed at: almost 4 years ago - Stars: 0 - Forks: 1

sharath-mohan/understanding-kafka
Guide on getting to know about kafka
Language: JavaScript - Size: 4.88 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

umakantv/kafka-nodejs
Kafka Node Integration
Language: JavaScript - Size: 184 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

wfl-junior/rocketseat-ignite-lab-node
A notifications microservice built with Nest
Language: TypeScript - Size: 188 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

marcosJuniorPassarella/notifications-microservice
Microservice developed using NestJs and more technologies and unitary tests using Jest.
Language: TypeScript - Size: 397 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

marcusviniciusfa/kafka-producer-to-notifications-service
Script para enviar mensagens, contendo notificações, para um Topic no Kafka
Language: JavaScript - Size: 1.95 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

miroswd/kafkajs
Learning kafka with kafka client
Language: JavaScript - Size: 18.6 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

borolgs/nestjs-kafka
Language: TypeScript - Size: 75.2 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

ignisilva/library-management-server
도서관 관리 API 및 Graphql 서버입니다
Language: JavaScript - Size: 156 KB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

parveenkumar-dev/kafkajs
Nodejs code to create connection with kafka js lib to produce and consume messages
Language: JavaScript - Size: 1.95 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

parveenkumar-dev/docker
Docker compose yaml file to create kafka server using docker images
Size: 1000 Bytes - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

LuoShiXi/egg-nodekafka
kafkajs for egg.
Language: JavaScript - Size: 669 KB - Last synced at: 5 months ago - Pushed at: over 5 years ago - Stars: 1 - Forks: 0

mrbrunelli/poc-nestjs-cluster-consumer
POC de uma aplicação NestJS + Kafka + Node Clusters
Language: TypeScript - Size: 99.6 KB - Last synced at: 3 months ago - Pushed at: almost 3 years ago - Stars: 1 - Forks: 0

okatsuo/kafka-prototype
Functional prototype to test kafka technology with asynchronous microservice
Language: TypeScript - Size: 38.1 KB - Last synced at: almost 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0

core-school/kafka-example
🚀 Kafka example: Fastify API written in typescript interacts with python processor
Language: TypeScript - Size: 27.3 KB - Last synced at: almost 2 years ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

yxlazy/kafka
kafka是一个分布式发布订阅消息系统,这里使用canal作为Producer,将mysql中的数据放入到kafka消息队列中,再通过kafkajs来消费数据
Language: TypeScript - Size: 26.4 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 1 - Forks: 0

nikitabathla/car-billing-service
A simple project that accepts car ID and entry time as inputs and returns total parking time and total parking charge as output.
Size: 46.9 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

fourthofaugust/kafkajs-typescript-example
A sample Kafka consumer and producer written in Typescript using Kafkajs.
Size: 5.86 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0

AdamHavlicek/nestjs-kafka-example
Microservices which use kafka as message broker
Language: TypeScript - Size: 122 KB - Last synced at: almost 2 years ago - Pushed at: almost 5 years ago - Stars: 1 - Forks: 0

xmanh/socket.io-kafkajs
KafkaJS adapter for socket.io
Language: TypeScript - Size: 21.5 KB - Last synced at: 9 days ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 1

yarncraft/ts-reactivekafka
Typesafe & reactive Kafka Subjects made with Typescript, KafkaJS and RxJS
Language: TypeScript - Size: 183 KB - Last synced at: 3 days ago - Pushed at: over 4 years ago - Stars: 1 - Forks: 0

MatheusAntonioF/kafka-node
A simple project to learn concepts of kafka using a lib kafkajs
Language: TypeScript - Size: 21.5 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

phambanhan/egg-apache-kafkajs
Kafkajs plugin for Egg.js
Language: JavaScript - Size: 892 KB - Last synced at: 23 days ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

vanchelo/kafka-sample-app
Dockerized Kafka and Zookeeper with KafkaJS client sample application.
Language: JavaScript - Size: 4.88 KB - Last synced at: about 1 year ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0
