Topic: "kafka-consumer"
AngelAlvarado/docker-streamsets-kafka-minecraft
Visualize Apache logs in Minecraft using Docker, Streamsets Data Collector, Spigot and Kafka .
Language: Shell - Size: 1.52 MB - Last synced at: about 2 years ago - Pushed at: about 7 years ago - Stars: 11 - Forks: 1

industrial-edge/Apache-Kafka-Connector
The Apache Kafka Connector connects to the IE Databus and Apache Kafka.
Language: Python - Size: 1.56 MB - Last synced at: 14 days ago - Pushed at: 4 months ago - Stars: 10 - Forks: 1

SpringBootCourses/data-store-microservice
This is data provider microservice for YouTube course.
Language: Java - Size: 30.3 KB - Last synced at: 12 months ago - Pushed at: about 1 year ago - Stars: 10 - Forks: 0

skroutz/rafka
Kafka proxy with a simple API, speaking the Redis protocol
Language: Go - Size: 354 KB - Last synced at: 19 days ago - Pushed at: about 2 years ago - Stars: 10 - Forks: 0

GavriloviciEduard/fastapi-kafka
Kafka PoC using FastAPI
Language: Python - Size: 5.86 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 10 - Forks: 6

quackscience/duckdb-extension-kafquack
Experimental DuckDB Kafka Consumer Extension
Language: C++ - Size: 22.5 KB - Last synced at: 16 days ago - Pushed at: 4 months ago - Stars: 9 - Forks: 0

mahdi-eth/GokafkaNotifer
A simple streamlined notification application that uses Kafka to efficiently handle the communication between producers and consumers for seamless notification delivery.
Language: Go - Size: 13.7 KB - Last synced at: 8 days ago - Pushed at: 9 months ago - Stars: 9 - Forks: 0

MBKraus/dockerized_data_science_playground
Multi-docker container data science / engineering playground (w/ Kafka, Airflow, MLFlow, Tensorflow-Keras / SKLearn) for simulating a microservices-oriented architecture
Language: Dockerfile - Size: 16.6 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 9 - Forks: 6

huangyueranbbc/KafkaDemo
Kafka整理
Language: Java - Size: 97.7 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 9 - Forks: 8

anshumanpattnaik/python-kafka-messaging
Python Kafka Messaging
Language: Python - Size: 412 KB - Last synced at: 20 days ago - Pushed at: over 4 years ago - Stars: 9 - Forks: 3

skroutz/rafka-rb
Ruby client library for Rafka
Language: Ruby - Size: 137 KB - Last synced at: 6 days ago - Pushed at: over 5 years ago - Stars: 9 - Forks: 5

apanagiotou/go-kafka-to-s3
An S3 Kafka Connector
Language: Go - Size: 1.22 MB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 9 - Forks: 1

thejasbabu/kafka-example
A simple Kafka Consumer and Producer example
Language: Java - Size: 9.77 KB - Last synced at: over 1 year ago - Pushed at: almost 7 years ago - Stars: 9 - Forks: 20

rrohitramsen/firehose
Firehose - Spark streaming 2.2 + Kafka 0.8_2
Language: Java - Size: 25.6 MB - Last synced at: 1 day ago - Pushed at: over 7 years ago - Stars: 9 - Forks: 7

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: 5 days ago - Stars: 8 - Forks: 2

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

scholzj/kafka-test-apps
Apache Kafka producers and consumers written in Vert.x
Language: Java - Size: 82 KB - Last synced at: 10 days ago - Pushed at: 4 months ago - Stars: 8 - Forks: 5

alexandresmoraes/mercadovila
Um aplicativo .NET de referência que implementa um aplicativo baseado em microserviços usando Kafka como broker de mensagens, Flutter como frontend e um gateway de acesso usando NGINX
Language: Dart - Size: 46.4 MB - Last synced at: 9 months ago - Pushed at: 9 months ago - Stars: 8 - Forks: 0

himash79/Spring-cloud-stream-with-Apache-Kafka
Build restful webservices utilizing Spring boot as well as intergrate Apache Kafka also manipulate with Spring Cloud Stream.
Language: Java - Size: 62.5 KB - Last synced at: 9 days ago - Pushed at: over 2 years ago - Stars: 8 - Forks: 0

himash79/Spring-boot-Apache-Kafka
Build restful webservices utilizing Spring boot as well as intergrate with Apache Kafka.
Language: Java - Size: 62.5 KB - Last synced at: 9 days ago - Pushed at: over 2 years ago - Stars: 8 - Forks: 0

CloudComputingProject-2022/Data_visualization_and_analysis_tool_for_telemetry_data
An naive anomaly detection and data visualization tool for F1 on board telemetry data.
Language: Python - Size: 1.4 MB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 8 - Forks: 1

victorhsr/vertx-retryable-kafka-consumer
Este projeto apresenta uma implementação de demonstração sobre como poderíamos utilizar mecanismos de retry e DLQ numa arquitetura event driven, utilizando-se do Apache Kafka, Vertx e RxJava.
Language: Java - Size: 152 KB - Last synced at: 15 days ago - Pushed at: about 3 years ago - Stars: 8 - Forks: 1

obalunenko/kafka-dump 📦
Kafka consumer that read data (multiply topics could be specified to )from kafka and write them to disk split by topic, date
Language: Go - Size: 3.46 MB - Last synced at: 10 months ago - Pushed at: about 4 years ago - Stars: 8 - Forks: 2

codegard/kafka-docker
Simple example of Kafka producer and consumer with Docker
Language: Java - Size: 26.4 KB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 8 - Forks: 8

charles-hsiao/robotframework-kafka
A Kafka python library for Robotframework to test events(messages) in Kafka.
Language: Python - Size: 3.91 KB - Last synced at: 17 days ago - Pushed at: about 7 years ago - Stars: 8 - Forks: 5

DataDog/datadog-kafka-connect-logs
A plugin for Kafka Connect to send Kafka records as logs to Datadog.
Language: Java - Size: 417 KB - Last synced at: 5 days ago - Pushed at: 3 months ago - Stars: 7 - Forks: 11

fmelihh/recommendation-engine
Generative AI & Recommendation Engine --- Firat University / Faculty of Technology / Software Engineering / Final Project
Language: Python - Size: 429 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 7 - Forks: 0

BSVN/Commons
Commons library
Language: C# - Size: 5.31 MB - Last synced at: 14 days ago - Pushed at: 6 months ago - Stars: 7 - Forks: 8

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

Team-Triage/triage
Triage is an open-source consumer proxy that solves head-of-line blocking for Kafka consumers
Language: Go - Size: 21.5 MB - Last synced at: 17 days ago - Pushed at: over 1 year ago - Stars: 7 - Forks: 0

purnima-jain/ports-and-adapters-kafka-with-avro
Spring Boot, Ports & Adapters Architecture with Kafka Producer-Consumer, Schema Registry & AVRO
Language: Java - Size: 14.6 KB - Last synced at: 12 months ago - Pushed at: over 2 years ago - Stars: 7 - Forks: 5

datanerds-io/verteiler
Meine dispatcher says there's something wrong mit deine Kabel. Java 8 BlockingQueue Kafka Consumer with automatically maintained offset.
Language: Java - Size: 32.2 KB - Last synced at: almost 2 years ago - Pushed at: over 6 years ago - Stars: 7 - Forks: 3

linhkikuchi/kafka-producer-consumer-java-example
A java example program for Producer/Consumer in a Kafka cluster
Language: Java - Size: 7.81 KB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 7 - Forks: 18

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

gdvalishvili1/eventrix
Kafka consumer for golang with partition-ordered concurrent processing and event handling
Language: Go - Size: 32.2 KB - Last synced at: 4 days ago - Pushed at: 10 days ago - Stars: 6 - Forks: 0

piomin/sample-spring-boot-kafka
Sample Spring Boot apps that sends and receives messages from Kafka using the Spring Kafka project
Language: Java - Size: 31.3 KB - Last synced at: 21 days ago - Pushed at: about 1 month ago - Stars: 6 - Forks: 6

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: 1 day ago - Pushed at: about 1 month ago - Stars: 6 - Forks: 0

Trendyol/kafkathena-commons
Smart, Fast, Customizable Consumer Configurations Common Utility Library
Language: Java - Size: 150 KB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 6 - Forks: 2

kalduzov/nkafka
.net native kafka library
Language: C# - Size: 1.61 MB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 6 - Forks: 0

leuchterag/Microsoft.Extensions.Hosting.Kafka
Libraries to host a Kafka consumer using the generic HostBuilder
Language: C# - Size: 64.5 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 6 - Forks: 5

aravindkumarsvg/nginx_logs_viewer_realtime_and_searchengine
Viewing the Nginx logs in Elasticsearch and in Realtime ETL using fluentd, kafka, mongodb, socket.io, elasticsearch, kibana
Language: HCL - Size: 3.41 MB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 2

Hungsiro506/spark-kafka-connector
Reliable spark-kafka connector. Kafka 1.x and Spark 2.x
Language: Scala - Size: 594 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 3

SheepGardener/alpaca-mq
a message queue that can realize service decoupling
Language: Go - Size: 63.5 KB - Last synced at: 10 months ago - Pushed at: over 4 years ago - Stars: 6 - Forks: 0

VictorGil/cadence_transfers_recording_service
Example/PoC of how to use Uber Cadence in order to implement event-driven microservices, together with Apache Kafka.
Language: Java - Size: 62.5 KB - Last synced at: about 2 years ago - Pushed at: about 5 years ago - Stars: 6 - Forks: 0

MobileTeleSystems/data-rentgen
NextGen DataMotion Lineage
Language: Python - Size: 1.99 MB - Last synced at: about 10 hours ago - Pushed at: 1 day ago - Stars: 5 - 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

ppatierno/kafka-playground
An Apache Kafka playground
Language: Java - Size: 61.5 KB - Last synced at: 21 days ago - Pushed at: 3 months ago - Stars: 5 - Forks: 1

konsumeio/konsume
:shipit: konsume seamlessly integrates message queues like RabbitMQ and Kafka with other services, automating data-driven actions.
Language: Go - Size: 488 KB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 5 - Forks: 2

wzlove/kafka2es
消费Kafka消息格式化处理后写入到ES
Language: Go - Size: 59.6 KB - Last synced at: 12 months ago - Pushed at: 12 months ago - Stars: 5 - Forks: 0

yassinessadi/movie-recommendation-als-spark
EC-JANE Entertainment launches an innovative film recommendation project utilizing MovieLens data. This project aims to incorporate Big Data analysis and machine learning to enhance movie suggestions, leveraging Apache Spark, Elasticsearch, and a Flask API to provide a personalized and dynamic user experience.
Language: Python - Size: 4.96 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 5 - Forks: 0

ettenauer/extension-confluent-kafka-client
The project extends functionality to confluent-kafka-dotnet by adding an abstraction layer with buffering.
Language: C# - Size: 195 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 5 - Forks: 2

313hemant313/TheGameNotification
A java spring boot standalone notification service
Language: Java - Size: 379 KB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 5 - Forks: 1

ar3s3ru/kprocessor
An ordered Kafka Consumer implementation for Go using franz-go
Language: Go - Size: 15.6 KB - Last synced at: 24 days ago - Pushed at: almost 3 years ago - Stars: 5 - Forks: 0

caleb-freitas/nestjs-kafka-integration
this project simulates product ordering and payment processing using producer/consumer with kafka
Language: TypeScript - Size: 494 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 5 - Forks: 0

allantargino/dotnet-kafka-parallel-consumer
.NET Kafka parallel consumer
Language: C# - Size: 28.3 KB - Last synced at: 23 days ago - Pushed at: almost 3 years ago - Stars: 5 - Forks: 2

saadhaxxan/Nodejs-Docker-Kafka-Microservice
Authentication Microservice that writes data to Mongodb and Postgres using Kafka Queue
Language: JavaScript - Size: 89.8 KB - Last synced at: about 2 years ago - Pushed at: about 3 years ago - Stars: 5 - Forks: 2

jaineil/uber-eats-clone
CMPE273 - Enterprise Distributed Systems (Lab 02)
Language: JavaScript - Size: 490 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 5 - Forks: 0

lnsycmy/NseMQ
NseMQ是NSE实验室内部使用的消息中间件,用于完成消息的统一封装和传输。 NseMQ基于C实现,集成了目前流行的 Kafka 消息系统和 Avro 序列化工具, 底层使用Kafka的C/C++客户端库 librdkafka 实现, 屏蔽了大量的使用细节,简单易用。
Language: C++ - Size: 22 MB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 5 - Forks: 4

zeroc0d3/learn-kafka-golang
Learning Kafka with Golang
Language: Python - Size: 56.6 MB - Last synced at: 24 days ago - Pushed at: about 4 years ago - Stars: 5 - Forks: 0

osodevops/kafka-audit-security-acls
Testing the audit logging of Confluent Kafka security ACLs
Language: Shell - Size: 26.4 KB - Last synced at: 12 months ago - Pushed at: over 4 years ago - Stars: 5 - Forks: 0

smartdu/kafkaclient-cpp
The Apache Kafka C++ library
Language: C++ - Size: 186 KB - Last synced at: over 1 year ago - Pushed at: almost 6 years ago - Stars: 5 - Forks: 1

syedhassaanahmed/hello-kafka-on-eventhubs-cs
Connecting to a Kafka-enabled Azure Event Hubs using Confluent's .NET Client
Language: C# - Size: 122 KB - Last synced at: 21 days ago - Pushed at: over 6 years ago - Stars: 5 - Forks: 1

mdvx/kafka-rtd
Excel RTD server sourcing data from Kafka
Language: C# - Size: 102 KB - Last synced at: about 2 years ago - Pushed at: almost 7 years ago - Stars: 5 - Forks: 3

anupkumarsharma/KafkaAvroNet
.Net based solution for using Kafka using Avro and Schema Registry
Language: C# - Size: 41 KB - Last synced at: 21 days ago - Pushed at: about 7 years ago - Stars: 5 - Forks: 0

exasol/kafka-connector-extension
Exasol Kafka Extension for accessing Apache Kafka
Language: Scala - Size: 749 KB - Last synced at: 13 days ago - Pushed at: 15 days ago - Stars: 4 - Forks: 7

vs4vijay/ELLI
A Microservice in NodeJS, Express, and Kafka to send out emails using SendGrid
Language: JavaScript - Size: 1.87 MB - Last synced at: 18 days ago - Pushed at: about 1 month ago - Stars: 4 - Forks: 3

Koldim2001/tg_bot_kafka
Телеграмм бот, отправляющий в чаты сообщения, приходящие в kafka
Language: Jupyter Notebook - Size: 13.7 KB - Last synced at: 11 days ago - Pushed at: 4 months ago - Stars: 4 - Forks: 0

rdcm/web-api
Web api application prototype written in rust and actix-web.
Language: Rust - Size: 189 KB - Last synced at: 12 days ago - Pushed at: 7 months ago - Stars: 4 - Forks: 0

wildonion/hoopoe
🕊️ a mesmerizing engine for handling realtime streaming process in a fully async and concurrent manner with Redis, RMQ and Kafka over WebSocket
Language: Rust - Size: 12.1 MB - Last synced at: 12 days ago - Pushed at: 7 months ago - Stars: 4 - Forks: 1

codefarm0/kafka
All about Kafka
Language: Java - Size: 210 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 4 - Forks: 2

supergloo/kafka-examples
Now, you may not believe this based on the repo name, but this repo contains Kafka examples. Amazing right!? Have fun out there folks
Language: Java - Size: 74.2 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 3

Shikha-code36/Real-Time-Stock-Price-Tracker-using-Kafka
A real time stock prices tracker using Kafka
Language: Python - Size: 7.81 KB - Last synced at: 20 days ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 1

Thomas-George-T/Covid19-Tweet-Data-Collection
Stream real time Tweets of current affairs like covid-19 using Kafka 2.0.0 high throughput producer & consumer into Elasticsearch using safe, idempotent and compression configurations. Aggregate the data and use it for further analytics.
Language: Java - Size: 130 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 1

dhohirpradana/ubuntu-kafka
Ubuntu with Kafka Installed
Size: 30.3 KB - Last synced at: 12 months ago - Pushed at: about 2 years ago - Stars: 4 - Forks: 0

divyeshBhartiya/SocialMediaPosts.Kafka
This repository demonstrates handling social media posts via Event Driven Architecture, Kafka and .NET6.
Language: C# - Size: 203 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 4 - Forks: 0

golang-queue/kafka
Kafak as backend for Queue Package
Size: 2.93 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 4 - Forks: 0

arconsis/Eshop-EDA 📦
Event driven microservices showcase. E-shop workflow based on event driven communication using Kafka
Language: HTML - Size: 9.82 MB - Last synced at: 5 months ago - Pushed at: about 3 years ago - Stars: 4 - Forks: 2

nikgalushko/kafka-drivers-competition
Compare golang kafka drivers
Language: Go - Size: 11.7 KB - Last synced at: 10 months ago - Pushed at: over 3 years ago - Stars: 4 - Forks: 1

cevheri/spark-tutorial
Apache Spark Tutorial - Scala, Java, Python code samples
Language: Scala - Size: 239 KB - Last synced at: 3 days ago - Pushed at: almost 4 years ago - Stars: 4 - Forks: 5

dabliuw22/fs2-kafka
Language: Scala - Size: 70.3 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 4 - Forks: 0

phantasmicmeans/spring-boot-kafka-consumer-dlq
Spring boot kafka consumer with DLQ and Retry. It supports 'spring-cloud-stream-kafka-streams-binder', 'spring-cloud-stream-kafka-binder', 'spring-kafka'
Language: Java - Size: 81.1 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 4 - Forks: 0

MitchelNijdam-Rockstars/kafka-retry-demo
Examples of retry mechanisms for spring-kafka consumer
Language: Kotlin - Size: 93.8 KB - Last synced at: almost 2 years ago - Pushed at: almost 5 years ago - Stars: 4 - Forks: 1

tmcgrath/kafka-examples
Wait for it.... Kafka Examples!
Language: Scala - Size: 10.7 KB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 1

luckyp71/cash-deposit
Cash Deposit App with Golang, Angular 6, and PostgreSQL
Language: TypeScript - Size: 7.71 MB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 4 - Forks: 1

rtortori/tetration-alfred
This is a Kafka consumer application written in Python that reads "questions" made by Cisco Tetration Analytics User Apps and take actions (i.e. send alerts via email, annotate flows)
Size: 1.05 MB - Last synced at: about 2 years ago - Pushed at: almost 7 years ago - Stars: 4 - Forks: 2

reddy-s/kafka-avro-consumer
Kafka consumer application which reads messages from Kafka and based on the schema registered in a schema registry and enriches the data. This is just a prototype on how we can efficiently evolve a schema and read messages with BACKWARD compatibility with out breaking the consumers. This application can be used as a base for a stateless stream processing application which would involve processing one event at a time or filtering though a stream of events.
Language: Java - Size: 145 KB - Last synced at: about 2 years ago - Pushed at: about 7 years ago - Stars: 4 - Forks: 3

LucasMagnum/kafka-examples
Kafka Examples
Size: 5.86 KB - Last synced at: about 1 month ago - Pushed at: over 7 years ago - Stars: 4 - Forks: 1

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

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: 19 days ago - Pushed at: 2 months ago - Stars: 3 - 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: 19 days ago - Pushed at: 2 months ago - Stars: 3 - Forks: 1

utair-digital/event-engine
Event engine - event driven framework
Language: Python - Size: 96.7 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 3 - Forks: 0

sivann/kafkatop
Monitor kafka consumer lags and event rates
Language: Python - Size: 1.4 MB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 3 - Forks: 0

Csini/spring-kafka-extensions
spring-kafka-extensions is a library that makes an entity based reactive approach (rxjava) to apache kafka possible, if you are using spring
Language: Java - Size: 1.4 MB - Last synced at: 4 days ago - Pushed at: 6 months ago - Stars: 3 - Forks: 0

OSSMafia/fastapi-kafka
A Kafka wrapper class around FastAPI to create consumers as endpoints.
Language: Python - Size: 27.3 KB - Last synced at: 13 days ago - Pushed at: 8 months ago - Stars: 3 - Forks: 1

rafaelrok/ms-order-pattern-saga-orchestrator
Projeto de microservices no padrão Saga de maneira de gerenciar a consistência de dados entre microservices em cenários de transação distribuída1. Uma saga é uma sequência de transações que atualiza cada serviço e publica uma mensagem ou evento para disparar a próxima etapa de transação utilizando o kafka.
Language: Java - Size: 5.82 MB - Last synced at: 22 days ago - Pushed at: 11 months ago - Stars: 3 - Forks: 2

abhinav-nath/all-about-kafka
A project that illustrates the usage and working of Apache Kafka
Language: Java - Size: 4.54 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 3 - 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: 21 days ago - Pushed at: about 1 year ago - Stars: 3 - Forks: 1

yassinessadi/movies-realtime-analysis
This project aims to develop a system capable of analyzing movie reviews in real-time using Kafka for data stream management and Memgraph for the graph database.
Language: Jupyter Notebook - Size: 2.43 MB - Last synced at: 12 months ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0

oguzhantasimaz/bynogame-price-analyst
Skin listings, price stats, price comparisons for Counter Strike between ByNoGame and Steam
Language: Go - Size: 793 KB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0

McTechie/node-kafka
A simplistic demonstration of Node.js and Kafka ⚡️
Language: JavaScript - Size: 948 KB - Last synced at: 12 months ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0
