hifly81/kafka-examples

Practical examples with Apache Kafka®

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

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: about 21 hours ago - Pushed at: about 22 hours ago - Stars: 0 - Forks: 0

strimzi/strimzi-kafka-bridge

An HTTP bridge for Apache Kafka®

Language: Java - Size: 2.61 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 305 - Forks: 125

karafka/karafka

Ruby and Rails efficient Kafka processing framework

Language: Ruby - Size: 6.36 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 2,150 - Forks: 184

confluentinc/vscode

Confluent for Visual Studio Code

Language: TypeScript - Size: 46.7 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 23 - Forks: 8

provectus/kafka-ui

Open-Source Web UI for Apache Kafka Management

Language: Java - Size: 29 MB - Last synced at: 2 days ago - Pushed at: 9 months ago - Stars: 10,654 - Forks: 1,267

confluentinc/librdkafka

The Apache Kafka C/C++ library

Language: C - Size: 34.2 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 580 - Forks: 3,192

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: 41.4 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 10 - Forks: 6

izaquegamer/flow-operators

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

Size: 1000 Bytes - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 0 - Forks: 0

loicgreffier/spring-boot-kafka-quickstarts

Code samples around Spring Boot and Kafka.

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

debezium/debezium

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

Language: Java - Size: 58.8 MB - Last synced at: 3 days ago - Pushed at: 7 days ago - Stars: 11,297 - Forks: 2,639

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

karafka/karafka-web

Web UI for monitoring and managing Karafka consumers

Language: Ruby - Size: 6.64 MB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 54 - Forks: 8

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 34.6 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 1,019 - Forks: 132

fgrosse/kafkactl

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

Language: Go - Size: 1.87 MB - Last synced at: 5 days ago - Pushed at: 6 days ago - Stars: 8 - Forks: 2

farel46/spring-cloud-stream-kafka

Some working examples of Spring Cloud Stream for Kafka

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

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: 64.5 KB - Last synced at: 6 days ago - Pushed at: 7 days ago - Stars: 0 - Forks: 0

simPod/PhpKafka

PHP Kafka boilerplate wrapper around RdKafka

Language: PHP - Size: 168 KB - Last synced at: 4 days ago - Pushed at: 7 days ago - Stars: 5 - Forks: 0

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

studiowebux/ledger

typescript experiment to build a ledger for learning, a bit inspired on the UTXO model

Language: TypeScript - Size: 99.6 KB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 0 - Forks: 0

xitonix/trubka

A CLI tool for Kafka

Language: Go - Size: 821 KB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 333 - Forks: 19

AhmetFurkanDEMIR/Data-Engineering-Project-with-HDFS-and-Kafka

Data Engineering Project with Hadoop HDFS and Kafka

Language: Python - Size: 3.46 MB - Last synced at: 8 days ago - Pushed at: over 1 year ago - Stars: 102 - Forks: 25

jrnd-io/jr

JR: streaming quality random data from the command line

Language: Go - Size: 2.75 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 133 - Forks: 29

source-c/clj-kafka-x

Clojure client for Apache Kafka

Language: Clojure - Size: 63.5 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 6 - Forks: 3

nomisRev/kotlin-kafka

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

Language: Kotlin - Size: 2.45 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 110 - Forks: 10

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: 10 days ago - Pushed at: 12 months ago - Stars: 2,454 - Forks: 289

neo4j-contrib/neo4j-streams

Neo4j Kafka Connector

Language: Kotlin - Size: 3.74 MB - Last synced at: 12 days ago - Pushed at: 14 days ago - Stars: 173 - Forks: 72

YouvaLo/logs-producer-kafka

API web développée selon la Clean Architecture en C# .Net. Elle permet de recevoir des logs et de les transmettre à un cluster Kafka pour un traitement ultérieur.

Size: 48.8 KB - Last synced at: 15 days ago - Pushed at: 15 days ago - Stars: 0 - Forks: 0

aliahmadcse/kafka-deck

Slides and Kafka Demo Project for Kafka Session

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

scylladb/scylla-cdc-source-connector

A Kafka source connector capturing Scylla CDC changes

Language: Java - Size: 1.05 MB - Last synced at: 14 days ago - Pushed at: 16 days ago - Stars: 51 - Forks: 20

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: 134 MB - Last synced at: 14 days ago - Pushed at: 14 days ago - Stars: 45 - Forks: 6

jorgermduarte/poc-csharp-kafka-project

Language: C# - Size: 230 KB - Last synced at: 7 days ago - Pushed at: over 1 year ago - Stars: 1 - 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: 14 days ago - Pushed at: 4 months ago - Stars: 377 - Forks: 143

floydspace/effect-kafka

📨 Effectful Kafka

Language: TypeScript - Size: 643 KB - Last synced at: 4 days ago - Pushed at: 3 months ago - Stars: 13 - Forks: 2

zillow/zkafka

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

Language: Go - Size: 329 KB - Last synced at: about 9 hours ago - Pushed at: about 1 month ago - Stars: 62 - Forks: 1

Trendyol/PollingOutboxPublisher

Outbox implementation for Kafka with Couchbase, MSSQL and PostgreSQL.

Language: C# - Size: 1.24 MB - Last synced at: 15 days ago - Pushed at: about 1 month ago - Stars: 27 - 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: 5 days ago - Pushed at: about 1 month ago - Stars: 72 - Forks: 6

ajanata/PretendYoureXyzzy

A web clone of the card game Cards Against Humanity.

Language: Java - Size: 12.2 MB - Last synced at: 16 days ago - Pushed at: over 1 year ago - Stars: 1,245 - Forks: 398

LearningJournal/Apache-Kafka-For-Absolute-Beginners

This is the central repository for all the materials related to Apache Kafka For Absolute Beginners Course by Prashant Pandey.

Language: Java - Size: 175 KB - Last synced at: 20 days ago - Pushed at: over 4 years ago - Stars: 84 - Forks: 148

piomin/sample-spring-kafka-transactions

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

Language: Java - Size: 52.7 KB - Last synced at: 14 days ago - Pushed at: 21 days ago - Stars: 40 - Forks: 38

PouyaPouryaie/springboot-kafka

This project demonstrates a simple kafka producer and consumer alongside another feature like error-handling, integration test with testcontainer and more

Language: Java - Size: 227 KB - Last synced at: 2 days ago - Pushed at: about 1 month ago - Stars: 6 - Forks: 0

limmer-laboratories/kafka-bundle

A symfony bundle for working with Kafka

Language: PHP - Size: 38.1 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 2 - Forks: 0

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: 17 days ago - Pushed at: 12 months ago - Stars: 85 - Forks: 38

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: 56.6 KB - Last synced at: 23 days ago - Pushed at: 23 days ago - Stars: 23 - Forks: 14

brentengelbrecht/kafka-producer

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

NAGARAJ08/kafka-replay

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

Language: Python - Size: 7.81 KB - Last synced at: 23 days ago - Pushed at: 24 days ago - Stars: 0 - Forks: 0

osodevops/CCAAK-Exam-Questions

Confluent Kafka questions to practice for CCAAK

Size: 32.2 KB - Last synced at: about 8 hours ago - Pushed at: about 2 months ago - Stars: 12 - Forks: 2

siddharthgupta5/Real-Time-Stock-Price-Tracker-using-Kafka

A real time stock prices tracker using Kafka

Language: Python - Size: 0 Bytes - Last synced at: 30 days ago - Pushed at: 30 days ago - Stars: 0 - Forks: 0

hoangtien2k3/microservice-webflux

Microservice-webflux with spring boot, reactor-core, Liquibase database migration, docker, apache kafka.

Language: Java - Size: 126 KB - Last synced at: 13 days ago - Pushed at: about 1 year ago - Stars: 7 - Forks: 4

tennyros/kafka-module-services

Kafka-producer-consumer workflow in spring-boot-multi-module project

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

san089/Optimizing-Public-Transportation

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

Language: Python - Size: 496 KB - Last synced at: 20 days ago - Pushed at: over 1 year ago - Stars: 30 - Forks: 14

clemensv/real-time-sources

Real Time Sources for Apache Kafka, Azure Event Hubs, and Fabric Event Streams

Language: Python - Size: 1.28 MB - Last synced at: 9 days ago - Pushed at: 3 months ago - Stars: 18 - Forks: 5

minhi0449/kafka

Apache Kafka와 Spring Boot를 활용한 실시간 메시지 스트리밍 아키텍처 구현 및 학습

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

aws-redhat-gameday/coffeeshop-app

Coffeeshop app services (frontend+backend)

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

joowani/kq

Kafka-based Job Queue for Python

Language: Python - Size: 108 KB - Last synced at: 11 days ago - Pushed at: about 3 years ago - Stars: 572 - Forks: 23

tennyros/product-microservice

Kafka producer microservice

Language: Java - Size: 14.6 KB - Last synced at: about 1 month ago - Pushed at: about 1 month 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: about 1 month ago - Pushed at: about 1 month ago - Stars: 325 - Forks: 69

fatihunlu/KafkaExamples

A collection of hands-on examples and demos for understanding Kafka concepts. Created to accompany my Medium articles.

Language: C# - Size: 15.6 KB - Last synced at: 17 days ago - Pushed at: 2 months ago - Stars: 2 - Forks: 0

miltiadiss/CEID_NE4348-Big-Data-Management-Systems

This project implements a real-time data pipeline with Kafka, Spark, and MongoDB. It generates vehicle data using UXSIM, streams it to a Kafka broker, processes it with Spark, and stores raw and processed data in MongoDB. Queries analyze vehicle counts, speeds, and routes over specified periods.

Language: Python - Size: 4.88 MB - Last synced at: 25 days ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

LearningJournal/ApacheKafkaTutorials

Example Code for Kafka Tutorials @ Learning Journal

Language: Java - Size: 20.5 KB - Last synced at: 14 days ago - Pushed at: over 7 years ago - Stars: 177 - Forks: 220

shkvik/nestjs-kafka-producer

This is a NestJS application developed as a producer for Apache Kafka. It provides a simple and efficient interface for sending messages in the Kafka topic, supporting asynchronous operations and flexible configuration of the microservice architecture.

Language: TypeScript - Size: 495 KB - Last synced at: 10 days ago - Pushed at: 6 months ago - Stars: 9 - Forks: 0

bersler/OpenLogReplicator

Open Source Oracle database CDC

Language: C++ - Size: 43 MB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 307 - Forks: 137

vipinsharma29/kafka-springboot-microservices

kafka-springboot-microservices

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

HariSekhon/Nagios-Plugin-Kafka

Kafka Scala API CLI / Advanced Nagios Plugin, with Kerberos support (uses Kafka 0.9+ native Java API)

Language: Shell - Size: 816 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 11 - Forks: 6

khorshuheng/kafka-protobuf-console

CLI tool to produce/consume Protobuf message to/from Kafka

Language: Go - Size: 25.4 KB - Last synced at: 12 days ago - Pushed at: over 5 years ago - Stars: 18 - Forks: 3

lilydjwg/filequeue

send logs to Kafka, using the log file like a queue, without rotation.

Language: Rust - Size: 20.5 KB - Last synced at: 12 days ago - Pushed at: almost 3 years ago - Stars: 5 - Forks: 0

MildredZarv/hola-kafka

Kafka Producer-Consumer Demo with Avro Serialization and Spring Boot (Dockerized)

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

cptlobster/aggregation-framework

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

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

chetanghadiya007/kafka_zookeeper_nodejs

Scalable Application Using Kafka, Zookeeper, and Node.js

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

LearningJournal/Kafka-Streams-Real-time-Stream-Processing

This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.

Language: Java - Size: 5.25 MB - Last synced at: 11 days ago - Pushed at: over 4 years ago - Stars: 164 - Forks: 163

maciek1839/kafka-producer-consumer

Kafka producer and consumer samples

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

jonathan-foucher/nodejs-kafka-avro-example

An example of kafka avro producer and consumer with nodejs

Language: JavaScript - Size: 32.2 KB - Last synced at: about 1 month ago - Pushed at: about 2 months ago - Stars: 0 - Forks: 0

tashi-2004/FMA-A-Dataset-For-Music-Analysis

Scripts for music feature analysis, model training, and real-time recommendation using Apache Kafka. Extract features, store them in MongoDB, and process the data with Apache Spark. A web interface is also included.

Language: Python - Size: 2.66 MB - Last synced at: 20 days ago - Pushed at: 2 months ago - Stars: 3 - Forks: 1

vipinsharma29/Kafka-idempotent-producer-consumer

Kafka-idempotent-producer-consumer

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

lpsm-dev/twitter-realtime-processing-covid

✔️ Twitter Realtime Processing about Covid-19 + Docker + Docker Compose + Apache Kafka + Elastic Stack (Elasticsearch + Kibana)

Language: Python - Size: 362 KB - Last synced at: 5 days ago - Pushed at: 19 days ago - Stars: 8 - Forks: 0

JavaCoDED78/data-producer-service

This application produces data and sends it to Data analyser service

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

jacintogomez/Financial-Market-Daily-Population

Populate database daily with live market information from FMP and EOD financial APIs

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

asem25/TechRadar

Tech Radar: Сервис для управления технологическим стеком и визуализации в формате техрадара

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

josephC45/Typeahead_Application

The Typeahead Application is a scalable and efficient system that provides real-time suggestions as users type.

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

edsonwade/kafka-demo-course

Apache Kafka is a distributed streaming platform that is used for building real-time data pipelines and streaming applications.

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

gitmehedi/techstacks

All kinds of R&D projects which are needed for my future implementation

Size: 47.2 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 3 - Forks: 0

AhmetFurkanDEMIR/airflow-spark-kafka-example

Airflow, Spark and Kafka example

Language: Dockerfile - Size: 532 KB - Last synced at: 8 days ago - Pushed at: over 1 year ago - Stars: 6 - Forks: 0

gislainemm/springboot3-kafka-producer

Springboot 3 Kafka Producer Demo API Project

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

H-Rusch/TimeTrials-Webservice

Spring Boot 3 webservice for saving and viewing times for time trials in Mario Kart 8 Deluxe

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

AkashBhuiyan/kafka-spring-boot

This is a Spring Boot-based Kafka Producer & Consumer Demo, designed to demonstrate event-driven architecture using Apache Kafka.

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

mikeroyal/Apache-Kafka-Guide

Apache Kafka Guide

Size: 203 KB - Last synced at: 12 days ago - Pushed at: over 3 years ago - Stars: 31 - Forks: 6

mookid8000/Topos

:cyclone: .NET Event Processing library

Language: C# - Size: 5.19 MB - Last synced at: about 7 hours ago - Pushed at: 2 months ago - Stars: 23 - Forks: 5

mukul273/springboot-kafka-tutorial

springboot kafka tutorial

Language: Java - Size: 3.22 MB - Last synced at: 14 days ago - Pushed at: 12 months 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: about 1 hour ago - Pushed at: about 2 hours ago - Stars: 29 - Forks: 3

tashi-2004/Apache-Kafka-and-Frequent-Item-sets

This Bash script automates the setup and execution of a data processing pipeline using Apache Kafka and Python scripts, ensuring fault tolerance and streamlined management of Kafka-based data pipelines.

Language: Python - Size: 146 KB - Last synced at: 20 days ago - Pushed at: 2 months ago - Stars: 3 - Forks: 0

s1ddh-rth/fake-kafka

A simulated Kafka data pipeline that generates fake customer and order data, processes it through Kafka, and stores it in PostgreSQL for real-time analysis with PySpark. Includes Kafdrop UI for monitoring. 🚀

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

idsulik/kafka-concepts-visualizer

Interactive visualization tool that helps developers understand Apache Kafka core concepts through animations. See how messages flow through topics and partitions, how consumer groups work, and how partition rebalancing happens when scaling consumers up or down.

Language: JavaScript - Size: 5.86 KB - Last synced at: 26 days ago - Pushed at: 5 months ago - Stars: 2 - Forks: 0

abrahamkoloboe27/Random-User-Streaming-Pipeline

Data Engeenering Project - Data Pipeline

Language: Jupyter Notebook - Size: 128 KB - Last synced at: 29 days ago - Pushed at: 5 months ago - Stars: 2 - Forks: 0

stereosky/community-highlights Fork of quixio/community-highlights

Collecting highlights from the Quix community and social media in the form of interesting questions, comments, challenges, solutions and insights

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

mahadev-chaurasiya/kafka-demo-app

Kafka Demo App

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

fhussonnois/kafka-examples

Examples of use of Apache Kafka Clients/KafkaStreams APIs

Language: Java - Size: 50.8 KB - Last synced at: 19 days ago - Pushed at: over 6 years ago - Stars: 13 - Forks: 15

Prabhakar-Naik/spring-kafka-app

Kafka application using spring boot The "spring-kafka-app" project is a Spring Boot application that demonstrates the integration of Apache Kafka with Spring Kafka for building scalable and reactive messaging systems. It showcases how to produce and consume messages asynchronously using Kafka topics and Spring Kafka's template and listener componen

Language: Java - Size: 186 KB - Last synced at: 15 days ago - Pushed at: 8 months ago - Stars: 0 - Forks: 0

saabeilin/kafkian

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

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

williamkoller/kafka-stream-processor

Kafka Stream Processor

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