memgraph/memgraph

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

Language: C++ - Size: 43.2 MB - Last synced at: about 4 hours ago - Pushed at: about 10 hours ago - Stars: 2,889 - Forks: 155

michelin/kstreamplify

Swiftly build and enhance your Kafka Streams applications.

Language: Java - Size: 3.62 MB - Last synced at: about 9 hours ago - Pushed at: about 10 hours ago - Stars: 129 - Forks: 24

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: 210 MB - Last synced at: about 2 hours ago - Pushed at: about 7 hours ago - Stars: 1,534 - Forks: 902

evolution-gaming/kafka-flow

library for reliable processing records received from kafka

Language: Scala - Size: 1.77 MB - Last synced at: about 19 hours ago - Pushed at: about 20 hours ago - Stars: 21 - Forks: 11

reugn/go-streams

A lightweight stream processing library for Go

Language: Go - Size: 598 KB - Last synced at: about 3 hours ago - Pushed at: 3 days ago - Stars: 2,036 - Forks: 164

robinhood/faust

Python Stream Processing

Language: Python - Size: 8.3 MB - Last synced at: about 14 hours ago - Pushed at: 10 months ago - Stars: 6,787 - Forks: 534

loicgreffier/spring-boot-kafka-quickstarts

Code samples around Spring Boot and Kafka.

Language: Java - Size: 49.5 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 17 - Forks: 6

provectus/kafka-ui

Open-Source Web UI for Apache Kafka Management

Language: Java - Size: 29 MB - Last synced at: 1 day ago - Pushed at: 10 months ago - Stars: 10,729 - Forks: 1,271

creek-service/basic-kafka-streams-demo

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

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

Nyagisa-chan/kafka-streams-template

Kafka Streams Template for honeypot project that I'm doing right now

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

typestreamio/typestream

Open Source streaming platform. Write and run typed data pipelines with a minimal, familiar syntax.

Language: Kotlin - Size: 8.05 MB - Last synced at: 3 days ago - Pushed at: 2 months ago - Stars: 72 - Forks: 5

strimzi/strimzi.github.io

Strimzi web site project

Language: HTML - Size: 119 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 32 - Forks: 74

jesperancinha/bridges-surveillance-story

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

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

Jaydip0724/fraud-detection-system

Fraud Detection Streaming Demo

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

JunYupK/CDC-PipeLine-With-Kafka

크롤링 데이터 CDC 파이프라인 프로젝트(feat. 뉴스 크롤링)

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

NeroHin/kafka-pyspark-streaming-tutorial

A hands-on tutorial for learning Kafka architecture and PySpark Streaming with stream-stream join, using Docker-based local simulation.

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

MinLee0210/kafka-learning

Learning how to use Kafka

Size: 3.91 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 0 - 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: 302 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 0 - Forks: 0

creek-service/ks-connected-services-demo

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

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

piotr-yuxuan/slava

Kafka Avro Serde for Clojure

Language: Clojure - Size: 1.33 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 7 - Forks: 0

piomin/sample-quarkus-kafka-streams

Quarkus and Kafka Streams Demo

Language: Java - Size: 95.7 KB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 12 - Forks: 16

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 34.7 MB - Last synced at: 6 days ago - Pushed at: 9 days ago - Stars: 1,054 - Forks: 138

bakdata/kpops

Deploy Kafka pipelines to Kubernetes

Language: Python - Size: 15.6 MB - Last synced at: about 11 hours ago - Pushed at: 7 days ago - Stars: 14 - Forks: 3

rtdi/RulesService

Implementation of a Kafka Cleansing, Validation, Enrichment service based on KStreams.

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

bakdata/streams-bootstrap

Utility functions and base classes for Kafka Streams applications

Language: Java - Size: 17.2 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 32 - Forks: 3

nayekabhishek1/awesome-kafka

A curated list about Apache Kafka

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

monksy/awesome-kafka

A collection of kafka-resources

Size: 101 KB - Last synced at: 5 days ago - Pushed at: about 2 months ago - Stars: 213 - Forks: 44

strimzi/strimzi-kafka-operator

Apache Kafka® running on Kubernetes

Language: Java - Size: 91.8 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 5,216 - Forks: 1,362

responsivedev/responsive-pub

A highly available and infinitely scalable, drop-in replacement for Kafka Streams

Language: Java - Size: 3.21 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 16 - Forks: 4

quarkiverse/quarkus-kafka-streams-processor

Easily build resilient Kafka Streams topologies based on the Processor API

Language: Java - Size: 500 KB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 7 - Forks: 8

masesgroup/KEFCore

Entity Framework Core provider for Apache Kafka™

Language: C# - Size: 54.9 MB - Last synced at: 4 days ago - Pushed at: 25 days ago - Stars: 7 - Forks: 1

cuongndc9/debezium-example

Debezium Example | Postgres ➡️ Elasticsearch

Language: Java - Size: 25.6 MB - Last synced at: 1 day ago - Pushed at: 10 days ago - Stars: 4 - Forks: 0

SeldonIO/seldon-server

Machine Learning Platform and Recommendation Engine built on Kubernetes

Language: Java - Size: 3.51 MB - Last synced at: 5 days ago - Pushed at: about 5 years ago - Stars: 1,472 - Forks: 299

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: 4 days ago - Pushed at: 11 days ago - Stars: 45 - Forks: 6

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: about 4 hours ago - Pushed at: 13 days ago - Stars: 14 - Forks: 2

IQKV/quickstart-kafka-stream-initialize

Initial code to start working with Kafka Streams.

Language: Java - Size: 277 KB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 0 - Forks: 0

Axual/ksml

Kafka Streams for Low Code Environments

Language: Java - Size: 2.13 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 25 - Forks: 11

creek-service/creek-kafka

Creek Kafka support

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

Angular2Guy/AngularAndSpring

This is an example application to show howto use Spring Boot 3, Angular 19, 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.

Language: Java - Size: 6.05 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 106 - Forks: 46

anasabbal/mini-uber-microservice

Nuber (Mini uber microservice - Spring Cloud) there is another version advanced but sorry it's private ( stable bransh B-STABLE-01 and refactor-03 )

Language: Java - Size: 399 MB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 16 - Forks: 7

michelin/kafka-streams-processing-error-handling

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

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

YunanJeong/kstreams-deploy

on Kubernetes

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

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

🍀 Spring Cloud Stream & Kafka Streams Binder + Processor API

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

loicgreffier/kafka Fork of apache/kafka

Mirror of Apache Kafka.

Language: Java - Size: 203 MB - Last synced at: 15 days ago - Pushed at: 16 days ago - Stars: 0 - Forks: 0

LGouellec/streamiz

.NET Stream Processing Library for Apache Kafka 🚀

Language: C# - Size: 12.4 MB - Last synced at: 6 days ago - Pushed at: about 2 months ago - Stars: 495 - Forks: 79

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: 170 MB - Last synced at: 14 days ago - Pushed at: 3 months ago - Stars: 385 - Forks: 48

osodevops/.github

Size: 51.8 KB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 0 - Forks: 0

rajadilipkolli/kafka-experiments

kakfa play ground

Language: Java - Size: 1.57 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 6 - Forks: 5

bakdata/kafka-error-handling

A library for error handling in Kafka Streams.

Language: Java - Size: 443 KB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 18 - Forks: 3

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: 499 KB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 59 - Forks: 9

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: 71.3 KB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 14 - Forks: 4

piomin/sample-spring-cloud-stream-kafka

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

Language: Java - Size: 78.1 KB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 39 - Forks: 34

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: 487 KB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 331 - Forks: 165

ivangfr/springboot-kafka-connect-jdbc-streams

Project goal: Explore Kafka, Kafka Connect, and Kafka Streams. Components: store-api: Inserts/updates MySQL records. Source Connectors: Monitor MySQL changes, push messages to Kafka. Sink Connectors: Listen to Kafka, insert/update Elasticsearch docs. store-streams: Listens to Kafka, processes with Kafka Streams, pushes new messages to Kafka.

Language: Java - Size: 283 MB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 113 - Forks: 72

infoslack/awesome-kafka

A list about Apache Kafka

Size: 96.7 KB - Last synced at: 13 days ago - Pushed at: 2 months ago - Stars: 581 - Forks: 163

hifly81/kafka-examples

Practical examples with Apache Kafka®

Language: Java - Size: 120 MB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 76 - Forks: 15

speedb-io/speedb

A RocksDB compliant high performance scalable embedded key-value store

Language: C++ - Size: 144 MB - Last synced at: 14 days ago - Pushed at: 11 months ago - Stars: 973 - Forks: 76

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: 24 days ago - Pushed at: 24 days ago - Stars: 0 - Forks: 0

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 7 hours ago - Pushed at: about 1 month ago - Stars: 302 - Forks: 90

juicycleff/nestjs-event-store

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

Language: TypeScript - Size: 550 KB - Last synced at: 5 days ago - Pushed at: over 2 years ago - Stars: 201 - Forks: 29

factorhouse/kpow

Kpow for Apache Kafka Release Artifacts

Language: Dockerfile - Size: 654 KB - Last synced at: 6 days ago - Pushed at: about 1 month ago - Stars: 43 - Forks: 5

iresil/FowlFlightForensics

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

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

gojek/ziggurat

A stream processing framework to build stateless applications on Kafka

Language: Clojure - Size: 1.48 MB - Last synced at: 2 days ago - Pushed at: 5 months ago - Stars: 402 - Forks: 64

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: 29 days ago - Pushed at: 30 days ago - Stars: 1 - Forks: 0

selcuksert/task-manager

Basic task management application based on event driven architecture paradigm

Language: JavaScript - Size: 16.9 MB - Last synced at: 14 days ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 0

lightbend/kafka-with-akka-streams-kafka-streams-tutorial

Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka

Language: Scala - Size: 79.8 MB - Last synced at: 11 days ago - Pushed at: almost 6 years ago - Stars: 212 - Forks: 71

adamko-dev/kotka-streams

Kotka Streams - the Kotlin DSL for Kafka Streams

Language: Kotlin - Size: 1010 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 16 - 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: 238 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

oslabs-beta/ksqlSuite

Node.js client for ksqlDB

Language: JavaScript - Size: 5.69 MB - Last synced at: 13 days ago - Pushed at: almost 2 years ago - Stars: 71 - Forks: 4

grafana/xk6-output-kafka

k6 extension to output real-time test metrics to a Kafka topic.

Language: Go - Size: 111 KB - Last synced at: 25 days ago - Pushed at: 11 months ago - Stars: 26 - Forks: 10

niqdev/zio-kafka-streams

Kafka Streams for Scala with ZIO

Language: Scala - Size: 147 KB - Last synced at: about 1 month ago - Pushed at: almost 4 years ago - Stars: 14 - Forks: 0

hguerrero/amq-examples

This repository contains a set of examples to be used with Red Hat AMQ messaging suite components.

Language: HTML - Size: 2.8 MB - Last synced at: 21 days ago - Pushed at: over 1 year ago - Stars: 40 - Forks: 45

thecodemonkey/kafka-microservices

A series of tiny examples around Kafka and event driven microservices using Spring Framework written in Kotlin & Java.

Language: Kotlin - Size: 3.02 MB - Last synced at: about 1 month ago - Pushed at: almost 4 years ago - Stars: 31 - Forks: 11

Tracing-Performance-Labs/dedup-analysis-pipeline

Kafka Streams pipeline to ingest and extract relevant data from OTEL traces

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

jaceklaskowski/kafka-workshop

Materials (slides and code) for Kafka and Kafka Streams Workshops

Language: JavaScript - Size: 9.6 MB - Last synced at: about 1 month ago - Pushed at: 11 months ago - Stars: 62 - Forks: 29

nayoung238/E-commerce-API

응답 속도 개선 및 효율적인 리소스 사용 방법 찾기 🤔

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

opentracing-contrib/java-kafka-client

OpenTracing Instrumentation for Apache Kafka Client

Language: Java - Size: 349 KB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 127 - Forks: 64

osodevops/CCAAK-Exam-Questions

Confluent Kafka questions to practice for CCAAK

Size: 32.2 KB - Last synced at: 3 days ago - Pushed at: 2 months ago - Stars: 12 - Forks: 2

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: about 1 month ago - Stars: 17 - Forks: 1

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: about 1 month ago - Pushed at: almost 2 years ago - Stars: 25 - Forks: 7

JustinBob39/StreamSystem

ETL

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

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: 18.8 MB - Last synced at: 2 days ago - Pushed at: over 2 years ago - Stars: 182 - Forks: 23

fhussonnois/kafkastreams-cep

Complex Event Processing on top of Kafka Streams

Language: Java - Size: 434 KB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 311 - Forks: 62

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

🍀 Spring Cloud Stream & Kafka Streams Binder - first steps

Language: Kotlin - Size: 304 KB - Last synced at: 28 days ago - Pushed at: about 2 months ago - Stars: 2 - Forks: 1

rogervinas/spring-cloud-stream-multibinder

🍀 Spring Cloud Stream Multibinder - Kafka & Kafka Streams

Language: Kotlin - Size: 227 KB - Last synced at: 28 days ago - Pushed at: about 2 months ago - Stars: 5 - Forks: 3

Synarcs/DNSObelisk

Enhanced observability and security framework built to fully prevent DNS exfiltration (C2, tunnelling) with no data loss using XDP, TC, Netfilter, BPF_MAPs. Ring Buffers, Running eBPF inside linux kernel and Deep Learning in user space and threat events streaming for dynamic blacklisting of malicious domains.

Language: Go - Size: 1.25 GB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 1

k1729p/Study04

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

RADAR-base/radar-commons

RADAR-base platform's common Java utilities library containing basic schemas, streaming features, testing bridges and utils.

Language: Kotlin - Size: 1.55 MB - Last synced at: 9 days ago - Pushed at: about 2 months ago - Stars: 2 - Forks: 4

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: over 1 year ago - Stars: 30 - Forks: 14

miyabayt/spring-cloud-kubernetes-sample

Language: Java - Size: 279 KB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 1 - Forks: 1

nodefluent/kafka-streams

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

Language: TypeScript - Size: 4.14 MB - Last synced at: 6 days ago - Pushed at: about 2 years ago - Stars: 835 - Forks: 111

bakdata/fluent-kafka-streams-tests

Fluent Kafka Streams Test with Java

Language: Java - Size: 600 KB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 89 - Forks: 16

AhmetFurkanDEMIR/Flink-Example

Flink Example

Language: Scala - Size: 5.6 MB - Last synced at: 28 days ago - Pushed at: over 1 year ago - Stars: 15 - Forks: 0

pathwaycom/pathway-benchmarks

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

Language: Python - Size: 4.7 MB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 68 - Forks: 4

matsumana/tsujun 📦

Yet another Web UI for KSQL

Language: Kotlin - Size: 248 KB - Last synced at: 10 days ago - Pushed at: almost 7 years ago - Stars: 53 - Forks: 9

bakdata/rebalancing-demo

Repository that showcases problems with Kafka rebalancing and explains how to fix them. Please visit our blog article to learn what Kafka rebalancing is, what can cause problems, and how to solve them. https://medium.com/bakdata/solving-my-weird-kafka-rebalancing-problems-c05e99535435

Language: Java - Size: 85 KB - Last synced at: about 1 month ago - Pushed at: over 4 years ago - Stars: 11 - Forks: 4

sergio11/iot_event_streaming_architecture

🌐📈 Unlock IoT potential with this Event Streaming Architecture: Apache Kafka and MQTT power real-time data handling. Visualize, analyze, and scale effortlessly. 🚀💻📊

Language: Java - Size: 27.5 MB - Last synced at: about 1 month ago - Pushed at: 2 months ago - Stars: 20 - Forks: 19

build-on-aws/prioritizing-event-processing-with-apache-kafka

Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.

Language: Java - Size: 585 KB - Last synced at: 7 days ago - Pushed at: 6 months ago - Stars: 28 - Forks: 8

perkss/clojure-kafka-examples

Clojure examples for Kafka and Kafka Streams (JAVA Interop)

Language: Clojure - Size: 115 KB - Last synced at: about 1 month ago - Pushed at: 8 months ago - Stars: 83 - Forks: 11

AymenDaoudi/FraudDetectionSystem

Event driven based local implementation of a fraud detection system in payment transactions, leveraging Kafka, Schema-Registry, Kafka Streams, KSQL

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