izaquegamer/flow-operators

🌊 Flow operators enable you to create restartable, pausable, or one-shot StateFlow.

Size: 1000 Bytes - Last synced at: about 5 hours ago - Pushed at: about 7 hours ago - Stars: 0 - Forks: 0

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 35 MB - Last synced at: about 9 hours ago - Pushed at: about 15 hours ago - Stars: 1,231 - Forks: 151

confluentinc/librdkafka

The Apache Kafka C/C++ library

Language: C - Size: 34.7 MB - Last synced at: about 7 hours ago - Pushed at: about 22 hours ago - Stars: 704 - Forks: 3,211

loicgreffier/spring-boot-kafka-quickstarts

Code samples around Spring Boot and Kafka.

Language: Java - Size: 49.8 MB - Last synced at: about 17 hours ago - Pushed at: 1 day ago - Stars: 20 - Forks: 7

ess-dmsc/event-formation-unit

(Mirror: moved to https://gitlab.esss.lu.se/ecdc/ess-dmsc/event-formation-unit) Implementation of neutron event formation pipeline for ESS

Language: C++ - Size: 42 MB - Last synced at: 1 day ago - Pushed at: 2 days ago - Stars: 10 - Forks: 6

dipjyotimetia/EventShark

kafka event streaming

Language: Go - Size: 296 KB - Last synced at: 1 day ago - Pushed at: 2 days ago - Stars: 1 - Forks: 0

manish-chet/fastapipythonkafka

FastAPI Python kafka

Language: Python - Size: 5.86 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 0 - Forks: 0

Deepshikha-yadav/expense-service

Microservice responsible for managing and tracking user expenses. Handles creation, retrieval, updating, and deletion of expense records, with support for categorization, date-based filtering, and integration with user and budgeting services.

Language: Java - Size: 24.4 KB - Last synced at: 2 days ago - Pushed at: 3 days ago - Stars: 0 - Forks: 0

farel46/spring-cloud-stream-kafka

Some working examples of Spring Cloud Stream for Kafka

Language: Java - Size: 18.6 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 0 - Forks: 0

starichkov/kafka-python-demo

Apache Kafka demo with Python JSON producer and polyglot-safe consumer.

Language: Python - Size: 49.8 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 0 - Forks: 0

NAGenaev/gpts-api-transfer-open

gpts-api-transfer-open

Language: Java - Size: 78.1 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 1 - Forks: 0

provectus/kafka-ui

Open-Source Web UI for Apache Kafka Management

Language: Java - Size: 29 MB - Last synced at: 4 days ago - Pushed at: 12 months ago - Stars: 11,043 - Forks: 1,293

neo4j-contrib/neo4j-streams

Neo4j Kafka Connector

Language: Kotlin - Size: 3.78 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 175 - Forks: 73

piomin/sample-spring-boot-saga-eventing

Demo presenting how to use Spring Cloud Stream and Spring Cloud Function with Apache Kafka broker to implement SAGA pattern in event-driven communication.

Language: Java - Size: 67.4 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 23 - Forks: 14

piomin/sample-spring-kafka-transactions

Spring Boot demo apps for testing Kafka transactions with other resources like database

Language: Java - Size: 59.6 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 40 - Forks: 38

karafka/karafka-web

Web UI for monitoring and managing Karafka consumers

Language: Ruby - Size: 7.47 MB - Last synced at: 2 days ago - Pushed at: 6 days ago - Stars: 55 - Forks: 10

confluentinc/vscode

Confluent for Visual Studio Code

Language: TypeScript - Size: 53.2 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 26 - Forks: 12

arasdenizhan/kafka-docker-example

Example project for my Medium article about running Kafka by using Docker Compose

Language: Java - Size: 14.6 KB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 0 - Forks: 0

debezium/debezium

Change data capture for a variety of databases. Please log issues at https://issues.redhat.com/browse/DBZ.

Language: Java - Size: 60.6 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 11,581 - Forks: 2,694

danielsobrado/CCDAK-Exam-Questions

Confluent Kafka questions to practice for CCDAK

Size: 539 KB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 146 - Forks: 57

floydspace/effect-kafka

📨 Effectful Kafka

Language: TypeScript - Size: 447 KB - Last synced at: 7 days ago - Pushed at: 10 days ago - Stars: 17 - Forks: 2

karafka/karafka

Ruby and Rails efficient Kafka processing framework

Language: Ruby - Size: 6.59 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 2,172 - Forks: 186

drisskhattabi6/Real-Time-Twitter-Sentiment-Analysis

This repo contains Big Data Project, its about "Real Time Twitter Sentiment Analysis via Kafka, Spark Streaming, MongoDB and Django Dashboard".

Language: Jupyter Notebook - Size: 5.09 MB - Last synced at: 5 days ago - Pushed at: about 1 year ago - Stars: 27 - Forks: 5

hakdogan/kafka-with-microservices

This repository is a tutorial for JUG Istanbul's Apache Kafka meetup that showing how Apache Kafka can be used in inter-microservices communication

Language: Java - Size: 1.03 MB - Last synced at: 2 days ago - Pushed at: almost 5 years ago - Stars: 40 - Forks: 13

RamonBecker/ms-saga

This repository presents a personal project focused on handling distributed transactions using the Orchestrated Saga Pattern. The goal is to build a robust microservices architecture capable of handling failures and maintaining data consistency without relying on the 2PC protocol.

Language: Java - Size: 101 MB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 0 - Forks: 0

strimzi/strimzi-kafka-bridge

An HTTP bridge for Apache Kafka®

Language: Java - Size: 2.62 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 308 - Forks: 125

saifuzzuhdi123/apache_kafka_stock_market_data_streaming

This repository provides a clear guide on using Apache Kafka for real-time stock market data streaming. 📈 Explore how to set up producers and consumers, and see practical applications in financial data processing. 🛠️

Language: Jupyter Notebook - Size: 2.46 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 0 - Forks: 0

zerodha/kaf-relay

Replicate and sync Kafka topics between clusters in realtime. Supports topic re-mapping, healthchecks, and hot failovers for high availability.

Language: Go - Size: 343 KB - Last synced at: 2 days ago - Pushed at: 4 months ago - Stars: 74 - Forks: 7

HoBom-s/hobom-event-processor

hobom event processor

Language: Go - Size: 61.5 KB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 1 - Forks: 0

simPod/PhpKafka

PHP Kafka boilerplate wrapper around RdKafka

Language: PHP - Size: 178 KB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 6 - Forks: 0

RishiBose961/MicroService-Kafkajs

Kafka

Language: JavaScript - Size: 0 Bytes - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 0 - Forks: 0

giobbu/online-root-cause-analysis

Online concept drift detection and explanation.

Language: Jupyter Notebook - Size: 4.35 MB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 0 - Forks: 0

streamthoughts/kafka-connect-file-pulse

🔗 A multipurpose Kafka Connect connector that makes it easy to parse, transform and stream any file, in any format, into Apache Kafka

Language: Java - Size: 16.5 MB - Last synced at: 12 days ago - Pushed at: 2 months ago - Stars: 332 - Forks: 71

wastech/url-shortener

A high-performance, scalable URL shortening service built with Spring Boot. This service provides fast URL shortening and retrieval with Redis caching, Kafka-based asynchronous processing, and PostgreSQL persistence.

Language: Java - Size: 61.5 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 1 - Forks: 0

eo-cqrs/eo-kafka

EO Kafka Producers and consumers for working with Apache Kafka message broker

Language: Java - Size: 1.38 MB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 28 - Forks: 3

sarkarshuvojit/kafka-sync-proxy

Make http calls to Kafka that waits for responses.

Language: Go - Size: 49.8 KB - Last synced at: 23 days ago - Pushed at: 23 days ago - Stars: 1 - Forks: 0

zekeriyyaa/PySpark-Structured-Streaming-ROS-Kafka-ApacheSpark-Cassandra

A structured streaming was applied to the robot data from ROS-Gazebo simulation environment using Apache Spark. Data is collected in Kafka, analyzed by Apache Spark and stored in Cassandra.

Language: Python - Size: 652 KB - Last synced at: 16 days ago - Pushed at: over 3 years ago - Stars: 19 - Forks: 6

Aiven-Labs/python-fake-data-producer-for-apache-kafka

The Python fake data producer for Apache Kafka® is a complete demo app allowing you to quickly produce JSON fake streaming datasets and push it to an Apache Kafka topic.

Language: Python - Size: 209 KB - Last synced at: 11 days ago - Pushed at: about 1 year ago - Stars: 85 - Forks: 38

zillow/zkafka

An efficient and scalable library for stateless Kafka message processing written in Go

Language: Go - Size: 385 KB - Last synced at: 19 days ago - Pushed at: 20 days ago - Stars: 63 - Forks: 1

fmelihh/recommendation-engine

Generative AI & Recommendation Engine --- Firat University / Faculty of Technology / Software Engineering / Final Project

Language: Python - Size: 3.69 MB - Last synced at: 30 days ago - Pushed at: about 1 month ago - Stars: 6 - Forks: 0

santiroldan/kafka-microservices

Implementación práctica de creación de usuarios con publicación de eventos (NestJS y Kafka)

Language: TypeScript - Size: 189 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

stefanoamorelli/kafka_dart

Apache Kafka in Dart using librdkafka FFI.

Language: Dart - Size: 194 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 2 - Forks: 0

J4C62/pms-booking-service

pms-booking is one of the core microservices of the Property Management System (PMS). Its responsibility is to manage property bookings, validate availability, and publish domain events like booking.created and booking.cancelled for processing by other services.

Language: Java - Size: 1.2 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

Pushpinder-singh/SB-Apache-Kafka

Spring boot microservices with kafka producer & consumers

Language: Java - Size: 29.3 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

mjones3/heart-rate-anomaly

A scalable pipeline for processing, synchronizing, and streaming patient ECG data in a time series database. Machine learning is used to detect heart rate anomalies.

Language: Python - Size: 51.8 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

averemee-si/oralog

Ingestion tool for various database logs

Language: Java - Size: 130 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 1

scylladb/scylla-cdc-source-connector

A Kafka source connector capturing Scylla CDC changes

Language: Java - Size: 1.07 MB - Last synced at: 26 days ago - Pushed at: about 1 month ago - Stars: 53 - Forks: 20

ahmadelmalah/kafka-playground

Kafka Playground

Language: Python - Size: 2.93 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

andremfaria/alarm-system-kafka

An alarm system that monitor hosts' CPU & memory indicators and send notifications according to user configurations

Language: Java - Size: 52.7 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 1

quantumbagel/PyAerial

PyAerial is scanning software for ADS-B in pure Python.

Language: Python - Size: 23.1 MB - Last synced at: 4 days ago - Pushed at: 10 months ago - Stars: 3 - Forks: 0

zendesk/delivery_boy

A simple way to publish messages to Kafka from Ruby applications

Language: Ruby - Size: 135 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 237 - Forks: 37

ronaldkanyepi/Log-Realtime-Analysis

A scalable architecture for real-time log processing and visualization. Built with a Kafka-Spark ETL pipeline, DynamoDB for storing aggregate real-time metrics, and Python Dash for interactive dashboards. Designed for high-throughput log ingestion, real-time monitoring, and long-term storage.

Language: Python - Size: 1.14 MB - Last synced at: about 1 month ago - Pushed at: 7 months ago - Stars: 4 - Forks: 0

osodevops/CCAAK-Exam-Questions

Confluent Kafka questions to practice for CCAAK

Size: 32.2 KB - Last synced at: 13 days ago - Pushed at: 5 months ago - Stars: 13 - Forks: 2

ori88c/keyed-batched-items-accumulator

A lightweight utility for Node.js projects that accumulates items into fixed-size batches per key, preserving insertion order within each key. Streams items directly into their respective batches at runtime, eliminating the overhead of post-processing 1D arrays into chunks. It abstracts key-based batch management.

Language: TypeScript - Size: 93.8 KB - Last synced at: 17 days ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

Dieg657/kafka-toolkit-lib

Advanced toolkit for Apache Kafka integration in Go, inspired by and built on top of Confluent's official Go client (confluent-kafka-go). Provides abstraction layers, simplified configuration, Schema Registry integration, and best practices for distributed applications, making Kafka usage easier and more performant in Go projects.

Language: Go - Size: 121 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

abdheshkumar/kafka-kotlin-app

Kafka producer consumer app in kotlin

Language: Kotlin - Size: 315 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 1 - Forks: 0

priyanshubiswas-tech/Real-Time-Stock-Data-Pipeline-using-Kafka-AWS-and-Python

built this project to simulate and stream stock market data in real time using Kafka. It includes a Python-based producer and consumer, stores data in AWS S3, and uses Athena for querying. Great hands-on experience with real-time data engineering!

Language: Python - Size: 21.5 KB - Last synced at: 18 days ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0

voylaf/IoTKafka

A Kafka Producer and Consumer written in Scala using FS2 with Confluent Schema Registry.

Language: Scala - Size: 94.7 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

BSVN/Commons

Commons library

Language: C# - Size: 5.31 MB - Last synced at: 15 days ago - Pushed at: about 2 months ago - Stars: 7 - Forks: 9

hifly81/kafka-examples

Practical examples with Apache Kafka®

Language: Java - Size: 120 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 78 - Forks: 16

sabrina-cardoso/investment-order-api

API de ordens de investimentos - Producer

Language: C# - Size: 14.6 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

cptlobster/aggregation-framework

A Swiss-army knife Scala library for scraping and processing data from the web.

Language: Scala - Size: 107 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0

masesgroup/KNet

KNet is a comprehensive .NET suite for Apache Kafka™ providing all features: Producer, Consumer, Admin, Streams, Connect, backends (ZooKeeper and Kafka)

Language: C# - Size: 138 MB - Last synced at: 3 days ago - Pushed at: 16 days ago - Stars: 44 - Forks: 6

NAGARAJ08/kafka-replay

A CLI tool to fetch Kafka messages within a specified time range

Language: Python - Size: 9.77 KB - Last synced at: 4 days ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

pratikgajjar/mysql-data-stream-kafka

This project create data stream from mysql using replication protocols and ingest into kafka. You can create event driven system using this.

Language: Python - Size: 7.81 KB - Last synced at: 1 day ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0

SayamMishra3/KafkaWithMicroservices_Tools

Simple Create a Kafka with Microservices .

Language: Java - Size: 12.7 KB - Last synced at: about 2 months ago - Pushed at: 3 months ago - Stars: 1 - Forks: 0

Anshumanshukla46/Event-driven-order-processing-system

Built a local event-driven order processing system using Spring Boot, Kafka, and Docker. Simulated asynchronous communication between microservices using producer-consumer patterns. Designed to mimic real-world, scalable backend systems with decoupled architecture.

Language: Java - Size: 102 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

nomisRev/kotlin-kafka

Kafka bindings for Kotlin `suspend`, and Kafka streaming operators for KotlinX Flow.

Language: Kotlin - Size: 2.46 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 111 - Forks: 10

ThurFerreira/Kafka-Feeder

A simple programam using kafka and spring boot to feed a kafka topic

Language: Java - Size: 4.88 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

Koyo-os/Poll-service

Poll service for survey web app

Language: Go - Size: 83 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

Telefonica/prometheus-kafka-adapter

Use Kafka as a remote storage database for Prometheus (remote write only)

Language: Go - Size: 32.1 MB - Last synced at: about 2 months ago - Pushed at: 7 months ago - Stars: 381 - Forks: 145

san089/Optimizing-Public-Transportation

A real-time event pipeline around Kafka Ecosystem for Chicago Transit Authority.

Language: Python - Size: 496 KB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 31 - Forks: 15

Castaglia/proftpd-mod_kafka

ProFTPD module for logging via Kafka

Language: C - Size: 170 KB - Last synced at: 28 days ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0

TIBCOSoftware/flogo

Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.

Language: CSS - Size: 32.4 MB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 2,459 - Forks: 291

aliahmadcse/kafka-deck

Slides and Kafka Demo Project for Kafka Session

Language: Java - Size: 6.17 MB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

YouvaLo/logs-kafka-producer

.NET web API organized according to a layered architecture. It exposes HTTP endpoints to receive logs and publish asynchronously to a Kafka cluster via Docker, providing a pipeline for collecting and distributing your logging events.

Size: 3.91 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

alexanderkhivrych/kafka-basics

Size: 19.5 KB - Last synced at: 4 days ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

joowani/kq

Kafka-based Job Queue for Python

Language: Python - Size: 108 KB - Last synced at: 22 days ago - Pushed at: over 3 years ago - Stars: 570 - Forks: 23

shreyash1080/GraphQLSolution

This repository is for learning new concepts and applying them here.

Language: C# - Size: 137 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 1 - Forks: 0

streamthoughts/kafka-clients-kotlin

This projects gives Kotlin bindings and several extensions for Apache Kafka Clients.

Language: Kotlin - Size: 158 KB - Last synced at: 11 days ago - Pushed at: over 3 years ago - Stars: 41 - Forks: 7

pyladiesams/kafka-clients-processing-data-streams-aug2025

Learn how to set up a Kafka producer client, then process the data to make it ready for downstream consumers. Discuss the basic of Kafka and get a handle on the different ways to process the data.

Language: Jupyter Notebook - Size: 722 KB - Last synced at: 9 days ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

jrnd-io/jr

JR: streaming quality random data from the command line

Language: Go - Size: 2.85 MB - Last synced at: about 2 months ago - Pushed at: 2 months ago - Stars: 133 - Forks: 29

ajanata/PretendYoureXyzzy

A web clone of the card game Cards Against Humanity.

Language: Java - Size: 12.2 MB - Last synced at: 2 months ago - Pushed at: almost 2 years ago - Stars: 1,249 - Forks: 398

pauloruszel/video_producer

Capture e envio de frames de vídeo (webcam, arquivo ou ONVIF) para o Kafka com Python e OpenCV.

Language: Python - Size: 0 Bytes - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

nayekabhishek1/awesome-kafka

A curated list about Apache Kafka

Size: 24.4 KB - Last synced at: 14 days ago - Pushed at: almost 3 years ago - Stars: 17 - Forks: 7

rohit-mehra/eye_of_sauron

Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.

Language: Python - Size: 134 MB - Last synced at: about 1 month ago - Pushed at: about 2 years ago - Stars: 59 - Forks: 28

SupTarr/go-kafka

Demonstrates a simple Kafka producer and consumer implementation in Go using the IBM/sarama library.

Language: Go - Size: 20.5 KB - Last synced at: 16 days ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

karlosvas/ordering-system Fork of lauvee/sistema-pedidos-grupo6

Proyecto Bytes Colaborativos: El sistema permite la creación, modificación, consulta y eliminación de pedidos y usuarios, además de la comunicación asincrónica de eventos mediante Apache Kafka junto con Kafka UI.

Language: Java - Size: 137 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

saabeilin/kafkian

An opinionated Kafka producer/consumer built on top of confluent-kafka-python/librdkafka

Language: Python - Size: 138 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 27 - Forks: 3

aryan735/Dellivery-Microservices

Language: Java - Size: 17.6 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

bersler/OpenLogReplicator

Open Source Oracle database CDC

Language: C++ - Size: 43.1 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 314 - Forks: 140

SimpleProgramming/springboot-kafka

A simple example to show how to use Spring Boot with Apache Kafka

Language: Java - Size: 13.7 KB - Last synced at: 21 days ago - Pushed at: over 3 years ago - Stars: 12 - Forks: 36

Green-Pulse/Data_Ingestion_Service

The Data Ingestion Service is responsible for fetching weather data from a public API, transforming it into internal format and forwarding it for analytics and storage

Language: Java - Size: 66.4 KB - Last synced at: about 2 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

EstebanDem/go-kafka-example

Simple example of microservices architecture with golang using kafka as broker

Language: Go - Size: 26.4 KB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 1

tashi-2004/Apache-Airflow-Kafka-Spark-DeltaLake-Real-Time-Stream-Pipeline

This project implements a real-time data pipeline using Apache Airflow, Kafka, Apache Spark, and Delta Lake. It supports both batch (Coldpath) and real-time (Hotpath) data ingestion, processing, and storage. Airflow is used for orchestrating the data workflows.

Language: Python - Size: 12.5 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

Jayanta-karmakar/kafka-spring-boot-integration

This repository contains a Spring Boot project integration with Apache Kafka. It showcases the setup for producing and consuming messages using Kafka.

Language: Java - Size: 34.2 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

fgrosse/kafkactl

kafkactl is a command line tool to interact with an Apache Kafka cluster.

Language: Go - Size: 1.87 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 8 - Forks: 2

Green-Pulse/Auth-Service

This microservice is responsible for: Authenticating users via Keycloak, Issuing and validating JWT tokens, Producing Kafka user registration and logging events

Language: Java - Size: 71.3 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

iresil/FowlFlightForensics

A Kafka-based CSV parser for bird-related airplane accidents

Language: Java - Size: 5.23 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 2 - Forks: 0

Qihoo360/qbusbridge

The Apache Kafka Client SDK

Language: C++ - Size: 611 KB - Last synced at: about 2 months ago - Pushed at: about 1 year ago - Stars: 291 - Forks: 73