strimzi/strimzi-kafka-operator

Apache Kafka® running on Kubernetes

Language: Java - Size: 82.4 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 5,564 - Forks: 1,420

masesgroup/KEFCore

Entity Framework Core provider for Apache Kafka™

Language: C# - Size: 51.9 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 7 - Forks: 1

loicgreffier/spring-boot-kafka-quickstarts

Code samples around Spring Boot and Kafka.

Language: Java - Size: 50 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 22 - Forks: 8

JayanthGummitha/CineStream

CineStream: Advanced OTT video streaming platform built with React, TypeScript, TailwindCSS, Node.js, and PostgreSQL. Features adaptive MPEG-DASH playback, captions, AI-powered recommendations, DRM support, and cross-device sync for seamless, high-performance video experiences.

Language: TypeScript - Size: 115 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 0 - Forks: 0

awaisajaz1/airflow_savant

A comprehensive data engineering pipeline has been established to coordinate the ingestion, processing, and storage of data. This pipeline utilizes Apache Airflow, Python, Apache Kafka, Apache Zookeeper, Apache Spark, and FastDBs. All these components have been containerized with Docker to facilitate straightforward deployment and scalability

Language: Python - Size: 535 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 5 - Forks: 3

memgraph/memgraph

Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.

Language: C++ - Size: 81.7 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 3,471 - Forks: 184

MohamedSamiHdj/realtime-data-pipeline

📊 Build a reliable real-time data pipeline for Windows using PySpark, ensuring quality data flow from raw ingestion to curated datasets.

Language: Python - Size: 1.3 MB - Last synced at: 4 days ago - Pushed at: 5 days ago - Stars: 0 - Forks: 0

Jaydip0724/fraud-detection-system

Fraud Detection Streaming Demo

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

wesleyscholl/SlipStream

⚡ Real-time fraud & anomaly detection system for streaming transactions. Built with Kafka Streams + Isolation Forest ML. Low-latency processing, online learning, and scalable architecture for detecting fraud patterns in transaction data. 🚨🔍

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

rajadilipkolli/kafka-experiments

kakfa play ground

Language: Java - Size: 2 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 7 - Forks: 5

piomin/sample-quarkus-kafka-streams

Quarkus and Kafka Streams Demo

Language: Java - Size: 127 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 13 - Forks: 16

evolution-gaming/kafka-flow

library for reliable processing records received from kafka

Language: Scala - Size: 1.96 MB - Last synced at: 6 days ago - Pushed at: 7 days ago - Stars: 21 - Forks: 11

provectus/kafka-ui

Open-Source Web UI for Apache Kafka Management

Language: Java - Size: 29 MB - Last synced at: 7 days ago - Pushed at: over 1 year ago - Stars: 11,592 - Forks: 1,341

michelin/kafka-streams-processing-error-handling

Code sample for processing error handling (KIP-1033).

Language: Java - Size: 23.4 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 4 - Forks: 1

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 35.7 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 1,704 - Forks: 212

Angular2Guy/AngularAndSpring

This is an example application to show howto use Spring Boot 3, Angular 20, Kafka with Streams and Mongodb with the reactive features of Spring in a clean architecture and a Helm chart for the Kubernetes setup. Structurizr is used for C4 diagrams. Standalone Components are used with Angular.

Language: Java - Size: 6.54 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 109 - Forks: 47

Axual/ksml

Kafka Streams without Java

Language: Java - Size: 7.66 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 28 - Forks: 14

pathwaycom/pathway-benchmarks

Benchmarks for data processing systems: Pathway, Spark, Flink, Kafka Streams

Language: Python - Size: 4.7 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 311 - Forks: 9

strimzi/strimzi.github.io

Strimzi web site project

Language: HTML - Size: 139 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 35 - Forks: 81

jesperancinha/bridges-surveillance-story

This application uses event sourcing to serve the logistics for a bridge management system.

Language: Kotlin - Size: 35.8 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 4 - Forks: 1

reugn/go-streams

A lightweight stream processing library for Go

Language: Go - Size: 561 KB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 2,125 - Forks: 172

piomin/sample-spring-kafka-datamesh

Several examples of application related to Spring Boot and Kafka components including KafkaConnect, KSQL or Kafka Streams

Language: Java - Size: 107 KB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 14 - Forks: 4

DHANUSH1323/banking

FinTech banking backend built with Spring Boot microservices and secured using Keycloak (OAuth2 + JWT). Demonstrates Eureka, API Gateway, Feign clients, and DTO–Entity mapping for scalable, secure, real-world systems.

Language: Java - Size: 128 KB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 0 - Forks: 0

littlehorse-enterprises/littlehorse

LittleHorse Kernel: A Platform for Distributed Event-Driven or Orchestrated Applications.

Language: Java - Size: 41 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 361 - Forks: 25

osodevops/.github

Size: 63.5 KB - Last synced at: 10 days ago - Pushed at: 11 days ago - Stars: 0 - Forks: 0

bakdata/streams-bootstrap

Utility functions and base classes for Kafka Streams applications

Language: Java - Size: 26.2 MB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 33 - Forks: 3

AhmadSuud/Real-Time-Web-Sessionization-with-PyFlink

Proyek Real-Time Web Sessionization with PyFlink membangun pipeline streaming menggunakan Apache Flink (PyFlink – Table API) untuk melakukan sessionization data web secara real-time. Pipeline ini membaca event JSON dari Kafka, mengelompokkan aktivitas pengguna berdasarkan IP dan host dengan session gap lima menit.

Language: Python - Size: 12.7 KB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 0 - Forks: 0

factorhouse/kpow

Kpow for Apache Kafka release artifacts

Language: Dockerfile - Size: 732 KB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 52 - Forks: 5

creek-service/creek-kafka

Creek Kafka support

Language: Java - Size: 2.46 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 5 - Forks: 0

bakdata/kafka-error-handling

A library for error handling in Kafka Streams.

Language: Java - Size: 520 KB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 19 - Forks: 3

QuickSign/kafka-encryption

Kafka End to End Encryption

Language: Java - Size: 199 KB - Last synced at: 6 days ago - Pushed at: about 2 years ago - Stars: 52 - Forks: 9

confluentinc/demo-scene

Scripts and samples to support Confluent Demos, Talks, and Blogs. Not all of the examples in this repository are kept up to date. For automated tutorials and QA'd code, see https://github.com/confluentinc/tutorials/

Language: Shell - Size: 211 MB - Last synced at: 16 days ago - Pushed at: 16 days ago - Stars: 1,558 - Forks: 911

speedb-io/speedb

A RocksDB compliant high performance scalable embedded key-value store

Language: C++ - Size: 144 MB - Last synced at: 8 days ago - Pushed at: over 1 year ago - Stars: 997 - Forks: 80

LGouellec/streamiz

.NET Stream Processing Library for Apache Kafka 🚀

Language: C# - Size: 12.6 MB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 520 - Forks: 78

michelin/avro-xml-mapper

Turn XML into Avro and vice versa.

Language: Java - Size: 320 KB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 19 - Forks: 7

VasilijeJukic01/MercilessWarrior-Java

Java 2D Platformer game. Made without using game engine.

Language: Java - Size: 145 MB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 6 - Forks: 2

loicgreffier/kafka Fork of apache/kafka

Mirror of Apache Kafka.

Language: Java - Size: 218 MB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 0 - Forks: 0

michelin/kstreamplify

Swiftly build and enhance your Kafka Streams applications.

Language: Java - Size: 3.83 MB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 139 - Forks: 26

infoslack/awesome-kafka

A list about Apache Kafka

Size: 96.7 KB - Last synced at: 14 days ago - Pushed at: 9 months ago - Stars: 583 - Forks: 165

masesgroup/KNet

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

Language: C# - Size: 158 MB - Last synced at: 12 days ago - Pushed at: 15 days ago - Stars: 47 - Forks: 6

rogervinas/spring-cloud-stream-kafka-streams-processor

🍀 Spring Cloud Stream & Kafka Streams Binder + Processor API

Language: Kotlin - Size: 357 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 1 - Forks: 3

rogervinas/spring-cloud-stream-multibinder

🍀 Spring Cloud Stream Multibinder - Kafka & Kafka Streams

Language: Kotlin - Size: 221 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 5 - Forks: 3

siddharthaDevineni/agentic-fraud-engine

Multi-agent AI fraud detection with Kafka streaming intelligence, makes decision smarter than tradititonal transaction analysis.

Language: Java - Size: 29.3 MB - Last synced at: 23 days ago - Pushed at: 23 days ago - Stars: 0 - Forks: 1

creek-service/ks-connected-services-demo

Extends the basic-kafka-streams-demo with a second service

Language: Java - Size: 2.27 MB - Last synced at: 23 days ago - Pushed at: 23 days ago - Stars: 1 - Forks: 0

hifly81/kafka-examples

Practical examples with Apache Kafka®

Language: Java - Size: 120 MB - Last synced at: 24 days ago - Pushed at: 24 days ago - Stars: 87 - Forks: 20

creek-service/basic-kafka-streams-demo

Get your head around the basics with this basic Kafka Streams microservice demo.

Language: Java - Size: 2.58 MB - Last synced at: 24 days ago - Pushed at: 24 days ago - Stars: 3 - Forks: 0

piomin/sample-spring-cloud-stream-kafka

Demo illustrating the usage of Spring Cloud Stream in order to integrate with Kafka Streams

Language: Java - Size: 96.7 KB - Last synced at: 24 days ago - Pushed at: 24 days ago - Stars: 40 - Forks: 35

airyhq/airy

💬 Open Source App Framework to build streaming apps with real-time data - 💎 Build real-time data pipelines and make real-time data universally accessible - 🤖 Join historical and real-time data in the stream to create smarter ML and AI applications. - ⚡ Standardize complex data ingestion and stream data to apps with pre-built connectors

Language: Java - Size: 169 MB - Last synced at: 2 days ago - Pushed at: 18 days ago - Stars: 398 - Forks: 49

beneite/JavaUtilities

This repo contains the custom utilities to support Automation framework. Please go through the readme file

Language: Java - Size: 236 MB - Last synced at: 27 days ago - Pushed at: 27 days ago - Stars: 1 - Forks: 0

monksy/awesome-kafka

A collection of kafka-resources

Size: 102 KB - Last synced at: 27 days ago - Pushed at: 27 days ago - Stars: 211 - Forks: 45

alexkimjr/EventHub

This is rustbootcamp capstone project using Rust within a 3-day timeframe. A high-throughput “front door” for event data - you send it events , and downstream systems can read and process those events in near real time. Small Actix Web service that accepts JSON POSTs at /ingest and forwards them to Kafka.

Language: Rust - Size: 43 KB - Last synced at: 28 days ago - Pushed at: 28 days ago - Stars: 0 - Forks: 0

bakdata/kafka-large-message-serde

A Kafka Serde that reads and writes records from and to Blob storage (S3, Azure, Google) transparently.

Language: Java - Size: 578 KB - Last synced at: 29 days ago - Pushed at: 29 days ago - Stars: 62 - Forks: 11

bakdata/fluent-kafka-streams-tests

Fluent Kafka Streams Test with Java

Language: Java - Size: 663 KB - Last synced at: 29 days ago - Pushed at: 29 days ago - Stars: 91 - Forks: 17

raphaelauv/kafka-stream-testing

Kafka Stream Test 100% programmatic

Language: Java - Size: 37.1 KB - Last synced at: 29 days ago - Pushed at: 29 days ago - Stars: 6 - Forks: 0

robinhood/faust

Python Stream Processing

Language: Python - Size: 8.3 MB - Last synced at: 26 days ago - Pushed at: over 1 year ago - Stars: 6,823 - Forks: 536

piomin/sample-spring-kafka-microservices

Example microservices showing how to use Kafka and Kafka Streams with Spring Boot on the example of distributed transactions implementations with the SAGA pattern

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

microsoft/data-accelerator

Data Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, editing and management of Spark jobs on Azure HDInsights or Databricks while enabling the full power of the Spark engine.

Language: C# - Size: 401 MB - Last synced at: about 1 month ago - Pushed at: 8 months ago - Stars: 306 - Forks: 91

kcmhub/KCM

Intuitive UI for Kafka Connect, Topics, ACLs, Schema Registry, etc.

Language: Shell - Size: 105 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 3 - Forks: 0

piotr-yuxuan/slava

Kafka Avro Serde for Clojure

Language: Clojure - Size: 1.35 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 7 - Forks: 0

mikeroyal/Apache-Kafka-Guide

Apache Kafka Guide

Size: 203 KB - Last synced at: 10 days ago - Pushed at: about 4 years ago - Stars: 66 - Forks: 12

manub/scalatest-embedded-kafka

A library that provides an in-memory Kafka instance to run your tests against.

Language: Scala - Size: 322 KB - Last synced at: 28 days ago - Pushed at: about 6 years ago - Stars: 294 - Forks: 83

bakdata/kpops

Deploy Kafka pipelines to Kubernetes

Language: Python - Size: 27.7 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 14 - Forks: 3

alikelleci/eventify

A functional Event Sourcing framework for Java using Apache Kafka

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

adamko-dev/kotka-streams

Kotka Streams - the Kotlin DSL for Kafka Streams

Language: Kotlin - Size: 1010 KB - Last synced at: 29 days ago - Pushed at: about 1 month ago - Stars: 16 - Forks: 0

alikelleci/easysourcing

A functional Event Sourcing framework for Java using Kafka for scalable event-driven architectures.

Language: Java - Size: 927 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 10 - Forks: 7

arminmokri/StreamProcessing

StreamProcessing is a collection of practical examples for learning stream processing with Java and Kafka Streams, focused on real tasks like filtering, mapping, aggregation, and event handling.

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

osodevops/CCAAK-Exam-Questions

Confluent Kafka questions to practice for CCAAK

Size: 32.2 KB - Last synced at: about 1 month ago - Pushed at: 9 months ago - Stars: 18 - Forks: 4

gojek/ziggurat

A stream processing framework to build stateless applications on Kafka

Language: Clojure - Size: 1.48 MB - Last synced at: 17 days ago - Pushed at: 12 months ago - Stars: 404 - Forks: 64

JBris/time-series-airflow-kafka-spark

A simple demonstration of an Airflow-Kafka-Spark (AKS) stack for online time series forecasting.

Language: Python - Size: 699 KB - Last synced at: 25 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

michelin/kafka-streams-ensure-explicit-resource-naming

Code sample for ensuring explicit resource naming in Kafka Streams (KIP-1111).

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

nodefluent/kafka-streams

equivalent to kafka-streams :octopus: for nodejs :sparkles::turtle::rocket::sparkles:

Language: TypeScript - Size: 4.14 MB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 839 - Forks: 111

juicycleff/nestjs-event-store

NestJS CQRS module for EventStore.org. It requires @nestjs/cqrs

Language: TypeScript - Size: 550 KB - Last synced at: about 2 months ago - Pushed at: about 3 years ago - Stars: 202 - Forks: 30

vvittis/CCFD-RF

Credit Card Fraudulent Detection with Random Forest

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

gAmUssA/one-does-not-simply-query-a-stream

WIP demos and code examples for how to query a stream talk

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

YunanJeong/kstreams-deploy

on Kubernetes

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

thriving-dev/kafka-streams-topology-design

Kafka Streams Topology Design (KSTD) is an open standard dedicated to the clear and effective description and visualization of Kafka Stream topologies.

Size: 131 MB - Last synced at: about 1 month ago - Pushed at: 4 months ago - Stars: 20 - Forks: 1

rogervinas/spring-cloud-stream-kafka-streams-first-steps

🍀 Spring Cloud Stream & Kafka Streams Binder - first steps

Language: Kotlin - Size: 300 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 2 - Forks: 1

streamthoughts/azkarra-streams

🚀 Azkarra is a lightweight java framework to make it easy to develop, deploy and manage cloud-native streaming microservices based on Apache Kafka Streams.

Language: HTML - Size: 19.1 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 182 - Forks: 23

SeldonIO/seldon-server

Machine Learning Platform and Recommendation Engine built on Kubernetes

Language: Java - Size: 3.51 MB - Last synced at: 2 months ago - Pushed at: over 5 years ago - Stars: 1,478 - Forks: 302

AlesiaSherstneva/event-driven-microservices-app

Я прохожу курс "Event-Driven Microservices: Spring Boot, Kafka and Elastic" на платформе Udemy.com.

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

eltonsandre/intellij-kafka

Intellij plugin Kafka Client: A powerful client for Apache Kafka. It provides support for multiple clusters, allowing you to efficiently manage topics, publish and consume messages, and perform various Kafka-related operations right within IntelliJ.

Size: 2.91 MB - Last synced at: 28 days ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0

confluentinc/learn-kafka-courses

Learn the basics of Apache Kafka® from leaders in the Kafka community with these video courses covering the Kafka ecosystem and hands-on exercises.

Language: Shell - Size: 41 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 38 - Forks: 89

javactrl/javactrl-kafka

Distributed, Scalable, Fault-Tolerant, Minimalistic Workflow Engine - No DAGs, No YAML, No Cumbersome Diagrams, Just Code

Language: Java - Size: 144 KB - Last synced at: 3 months ago - Pushed at: 7 months ago - Stars: 13 - Forks: 2

thriving-dev/kafka-streams-cassandra-state-store

'Drop-in' Kafka Streams State Store implementation that persists data to Apache Cassandra / ScyllaDB

Language: Java - Size: 1.37 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 25 - Forks: 5

Hurence/logisland

Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.

Language: Java - Size: 120 MB - Last synced at: 3 months ago - Pushed at: about 2 years ago - Stars: 109 - Forks: 30

natengall/kafka-meld

REST API to facilitate Kafka and Kafka Connect operations

Language: Java - Size: 22.5 KB - Last synced at: 3 months ago - Pushed at: almost 6 years ago - Stars: 2 - Forks: 0

vepo/imersao-kafka

Curso básico sobre Apache Kafka

Language: Java - Size: 117 MB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 30 - Forks: 6

creek-service/wip-state-stores-demo

Extends the basic-kafka-streams-demo with a second service

Language: Java - Size: 1.27 MB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0

quarkiverse/quarkus-kafka-streams-processor

Easily build resilient Kafka Streams topologies based on the Processor API

Language: Java - Size: 640 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 8 - Forks: 8

stevehoober254/Real-time-Data-Pipeline-with-Apache-Kafka

Real-time data pipeline using Apache Kafka for ingesting, processing, and analyzing streaming data.

Size: 702 KB - Last synced at: 3 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0

praveenkumardec89/location-tracking-system-design

An approach to design a location tracking system at a high level

Size: 807 KB - Last synced at: 3 months ago - Pushed at: over 5 years ago - Stars: 14 - Forks: 2

Shuttle/Shuttle.Esb

A highly extensible service bus implementation.

Language: C# - Size: 1.96 MB - Last synced at: 3 months ago - Pushed at: 9 months ago - Stars: 96 - Forks: 30

zhang-hongshen/leadnews

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

alfakini/workshop-codecon-kafka

Exemplos do workshop realizado na codecon.dev sobre arquitetura event-driven com Apache Kafka.

Language: Java - Size: 37.1 KB - Last synced at: about 1 month ago - Pushed at: about 5 years ago - Stars: 12 - Forks: 4

AndrewKuzmin/Kafka-Streams-DSL-for-Scala-examples

Kafka Streams DSL for Scala examples

Language: Scala - Size: 11.7 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0

garystafford/streaming-sales-generator

Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python

Language: Python - Size: 9.28 MB - Last synced at: 4 months ago - Pushed at: almost 3 years ago - Stars: 44 - Forks: 21

DishaBasti/real-time-analytics-pipeline

Live viewership analytics using Kafka, PySpark, forecasting, and Grafana dashboards

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

Ankush-Paul-02/Asteroid-Collision-Notification

A reactive Spring Boot service that fetches asteroid data from NASA's API, detects hazardous asteroids, and sends real-time Kafka-based notifications for potential collisions.

Language: Java - Size: 22.5 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

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: 4 months ago - Pushed at: 11 months ago - Stars: 5 - Forks: 0

kishlayjeet/Stock-Market-Real-Time-Data-Pipeline-with-Apache-Kafka-and-Cassandra

A end-to-end real-time stock market data pipeline with Python, AWS EC2, Apache Kafka, and Cassandra Data is processed on AWS EC2 with Apache Kafka and stored in a local Cassandra database.

Language: Python - Size: 2.3 MB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 25 - Forks: 8