Topic: "kafka-consumer"
yassinejouao/kafka-js-socket
This repository provide a solution for integrating Kafka, a distributed streaming platform, with WebSocket, a communication protocol, using JavaScript. is currently under development.
Language: Python - Size: 32.2 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 0
Sahil-4555/go-kafka
This is a simple Go web server that implements a Kafka producer and consumer using the Fiber web framework. The server has two endpoints: one for sending data to the Kafka producer and another for receiving data from the Kafka consumer.
Language: Go - Size: 11.7 KB - Last synced at: 7 days ago - Pushed at: almost 2 years ago - Stars: 3 - Forks: 1
majusko/rx-kafka
RxKafka - Reactive wrapper for well known C++ kafka library rdkafka
Language: TypeScript - Size: 186 KB - Last synced at: 5 days ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 1
zBrainiac/StreamAnalytics
Language: Java - Size: 2.94 MB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 2
mgrzybek/observability-datahub-k8s-terraform
Read logs and metrics from Kafka topics and send them to S3, split GPDR logs and tech logs
Language: HCL - Size: 89.8 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0
ankurbhambri/kafka_learning
Learning Kafka Standalone and Distributed Mode
Language: Python - Size: 3.26 MB - Last synced at: 12 months ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0
shametha/Binary-Brains---Deep-Integration
3 input files - An XML, a JSON, a CSV file is read and written into 3 different databases - SQL, Reddis, Mongo using Kafka
Language: Java - Size: 30.3 KB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 0
shametha/Kafka-Implementation-using-Java
Language: Java - Size: 10.7 KB - Last synced at: over 1 year ago - Pushed at: almost 3 years ago - Stars: 3 - Forks: 0
beatriz-dadalto/kafka-com-spring-udemy
Estudando Kafka com Spring
Language: Java - Size: 71.3 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 3 - Forks: 0
Karim-love/kafka_basic
kafka의 기본 동작에 대해 pkg별로 구현한 프로젝트입니다.
Language: Java - Size: 88.9 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 3 - Forks: 0
gurkanakdeniz/dent
simple linkedin crawler
Language: Java - Size: 1.04 MB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 3 - Forks: 1
caponetto/streaming-dmn-kafka
Streaming decisions with DMN and Kafka
Language: Java - Size: 259 KB - Last synced at: 12 months ago - Pushed at: almost 4 years ago - Stars: 3 - Forks: 3
stephan-mueller/kafka-api-showcase 📦
The showcase demonstrate various APIs to communicate with Apache Kafka
Language: Java - Size: 9.18 MB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 3
jresearchsoftware/open-gavka
Kafka monitor tools. Topic browser, consumer activity monitor
Language: Java - Size: 7.77 MB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 0
aren89/MyFirstGoWebServer
Language: Go - Size: 58.6 KB - Last synced at: over 1 year ago - Pushed at: almost 5 years ago - Stars: 3 - Forks: 0
san089/SF-Crime-Statistics
A Kafka and Spark Streaming Integration project : SF Crime Statistics with Spark Streaming
Language: Python - Size: 3.42 MB - Last synced at: 11 days ago - Pushed at: about 5 years ago - Stars: 3 - Forks: 5
peepeepopapapeepeepo/zabbix-kafka-monitoring
Language: Shell - Size: 30.3 KB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 1
imrahulr/Predictive-Threat-Intelligence
Machine Learning and Big Data based Threat Intelligence
Language: Jupyter Notebook - Size: 7.35 MB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 0
hartmut-co-uk/kafka-delayed-consumer-example
Test/example (python) project of a client-side delayed kafka consumer approach based on kafka message timestamp, sleep.
Language: Python - Size: 9.77 KB - Last synced at: 23 days ago - Pushed at: over 6 years ago - Stars: 3 - Forks: 0
yanserliu/consumer
beego xorm kafka dgraph
Language: Go - Size: 17.3 MB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 3 - Forks: 1
iresil/FowlFlightForensics
A Kafka-based CSV parser for bird-related airplane accidents
Language: Java - Size: 5.23 MB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 2 - Forks: 0
limmer-laboratories/kafka-bundle
A symfony bundle for working with Kafka
Language: PHP - Size: 38.1 KB - Last synced at: 24 days ago - Pushed at: 24 days ago - Stars: 2 - Forks: 0
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: 19 days ago - Pushed at: 2 months ago - Stars: 2 - Forks: 0
shubhamch95/Real-Time-Polling-System
A scalable system using Node.js, PostgreSQL, Kafka, and WebSocket for creating polls, casting votes, and real-time result updates. It features RESTful APIs, leaderboards, and dynamic vote tracking.
Language: JavaScript - Size: 4.82 MB - Last synced at: 21 days ago - Pushed at: 4 months ago - Stars: 2 - Forks: 0
Inozpavel/kafka-reader
Web api for reading and filtering kafka messages in different formats
Language: Rust - Size: 280 KB - Last synced at: 14 days ago - Pushed at: 5 months ago - Stars: 2 - 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: 28 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: about 1 month ago - Pushed at: 5 months ago - Stars: 2 - Forks: 0
MelihcanSimsek/MicroserviceFoodDelivery
Microservice Architecture Concept For Food Delivery System With Spring Boot using Apache Kafka
Language: Java - Size: 225 KB - Last synced at: 22 days ago - Pushed at: 6 months ago - Stars: 2 - Forks: 1
PHPQueueManager/Application
It is a consumer application framework that provides abstraction of job queues and jobs. Provides excellent scaling.
Language: PHP - Size: 16.6 KB - Last synced at: 5 months ago - Pushed at: 8 months ago - Stars: 2 - Forks: 0
senghor/express-kafka
How to get started with Kafka, NodeJS & ExpressJS
Language: JavaScript - Size: 19.5 KB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 2 - Forks: 0
VinukaThejana/notifications
A simple notification system with live notification streaming powered by Kafka
Language: Go - Size: 17.6 KB - Last synced at: 8 days ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0
rafaeltedesco/openticket-microservices
An application developed to demonstrate the operation and how to create microservices, using different programming languages for each microservice, such as: Python with FastAPI, Java with Spring Boot, Golang, JavaScript with Nest.js, JavaScript with Express and Apache Kafka as Message Broker.
Language: Java - Size: 689 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0
open-source-ts/kafka-message-bus
Kafka Message Bus is a KafkaJS wrapper enhancing its functionality with deadletter topic support and handlers, improving Kafka stream reliability by managing failed message processing. 🚀
Language: TypeScript - Size: 90.8 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0
vinaycharlie01/messagesystem-go
simple message queuing system using the Go programming language with Kafka as the underlying message broker
Language: Go - Size: 110 KB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0
AndreProenza/Autonomous-Vehicle-As-A-Service
A cloud-based system that aims at the integration between car manufacturers, autopilot developers, users, and other external service providers.
Language: Java - Size: 21.9 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0
shaikrasheed99/golang-kafka-producer-consumer
Kafka Producer & Consumer applications in Golang.
Language: Go - Size: 9.77 KB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0
AnastasiaP261/financial_tg_bot
Проект написанный во время OZON Route256. Реализован телеграм-бот "Финансовый помощник"
Language: Go - Size: 717 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0
abhishekkathayat/Centralized-Kafka
Kafka Configuration, Consumer and Producer Centralization.
Language: Java - Size: 84 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0
has-abi/fastapi-serving-kafka
Decopled serving stack using FastAPI, Kafka, and MongoDB - Example
Language: Python - Size: 76.2 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 0
tmvolpato/choreography-saga-pattern
Saga Pattern
Language: Java - Size: 747 KB - Last synced at: 2 months ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 1
xoxoist/oni
👺 Echo or Gin like kafka API wrapper for kafka-go
Language: Go - Size: 730 KB - Last synced at: 1 day ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 0
CIPHERTron/kafka-streamer
A microservice that uses Kafka to listens to an event involving order creation and then insert the product orders to a PostgreSQL database.
Language: Python - Size: 584 KB - Last synced at: 2 months ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 1
suriyakrishna/scala-kafka-application
Repository with sample code to build Kafka Streaming Application in Scala.
Language: Scala - Size: 30.3 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 0
rjerez1992/edgerunner-kafka-ui
Multiplatform desktop Apache Kafka UI tool for producing and consuming messages based on templates to multiple clusters.
Language: TypeScript - Size: 7.96 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 0
acata8/IOT-BC-TBDM
Prototype to consumed data in real-time from Apache Kafka and forward it to BigchainDb.
Language: JavaScript - Size: 9.66 MB - Last synced at: 2 months ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 0
dbgjerez/workshop-amq-streams
An example with AMQ Streams, SQL Database and GitOps
Language: JavaScript - Size: 2.83 MB - Last synced at: 11 days ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 3
Eainde/eainde-kafka
This is kafka producer and consumer POC. I am using avro serializer for serialization and deserialization of kafka messages.
Language: Java - Size: 19.5 KB - Last synced at: over 1 year ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 0
NikSoftelevation/apache-kafka-real-time-project
Apache Kafka with spring boot
Language: Java - Size: 68.4 KB - Last synced at: over 1 year ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 0
jretty-org/kafka-xclient
A third-part enhanced edition of Apache official kafka-clients. The 'Best practice' of kafka consumer and producer.
Language: Java - Size: 43.9 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 3
bbatjargal/BDTwitrend
The class project of Big Data Technology course in March 2018 at MUM
Language: Java - Size: 43.3 MB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 0
jSarthak-987/washub-nodejs-kafka-client-api
Apache Kafka client API for nodejs based services of Washub
Language: JavaScript - Size: 61.5 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0
Antonio-Borges-Rufino/IoT_Data_Enginer_Streaming
Tipo: Engenharia de dados. Tecnologias: Spark Streaming, Apache Kafka, Apache Hadoop, Redis, Api Rest.
Language: Jupyter Notebook - Size: 754 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0
Antonio-Borges-Rufino/Dados_Aeronauticos_Data_Pipeline
Tipo: Engenharia de dados. Tecnologias: Apache Nifi, Apache Druid, Api Rest, MySql, Apache Hadoop, Apache Hive, Apache Kafka.
Language: Jupyter Notebook - Size: 5.24 MB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0
Artemas-Muzanenhamo/party-reservation
An application to make party reservations the non-blocking way.
Language: Java - Size: 243 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0
spdpiyush/kafka-project
This repository contains basic example of kafka & with some advance example like taking real time tweets from twitter and those tweets Produced into Kafka and then end up into the Elastic Search.
Language: Java - Size: 57.6 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0
Nasruddin/data-streaming-kafka-protobuf-golang-java
Data streaming between Java and Golang service with Kafka using Protocol Buffers
Language: Java - Size: 67.4 KB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0
alessandroargentieri/java-messaging
Java async messaging using AWS SNS-SQS, RabbitMQ, ActiveMQ, Kafka and API notifications
Language: Java - Size: 154 KB - Last synced at: 9 days ago - Pushed at: almost 3 years ago - Stars: 2 - Forks: 2
jcmdsbr/poc-sqlserver-debezium-kafka-consumer
POC CDC use SQL Server and Debezium + Kafka
Language: C# - Size: 7.81 KB - Last synced at: about 1 month ago - Pushed at: about 3 years ago - Stars: 2 - Forks: 0
nathy-mesquita/kafka
Projeto de estudo sobre a utilização do Kafka com C#
Language: C# - Size: 20.5 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0
ManikHossain08/Realtime-ETL-DataPipeline-Using-Avro_Schema_Registry-Spark-Kafka-HDFS-Hive-Scala
Bigdata processing (Realtime ETL DataPipeline) using Avro Schema Registry, Spark, Kafka, HDFS, Hive, Scala, docker, spark-streaming
Language: Scala - Size: 1.36 MB - Last synced at: almost 2 years ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0
harishch1998/Traveller-kafka
A Distributed Systems project using kafka, spring boot and docker
Language: Java - Size: 965 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0
nerdynick/kafka-lag-exporter-ansible
Ansible Roles for the Lightbend Kafka Lag Exporter
Language: Jinja - Size: 36.1 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 2
jjeanjacques10/alura-ecommerce-kafka
Aplicação desenvolvida na formação Kafka da Alura
Language: Java - Size: 114 KB - Last synced at: 12 months ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0
dangnm9699/imdb-scraping-and-analysing
Big data storage and processing / HUST / 20201
Language: Go - Size: 55.7 KB - Last synced at: 28 days ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0
ramadani/starboost
Kafka event client tool
Language: Go - Size: 19.5 KB - Last synced at: 26 days ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0
Alarm-Integration/sms-service
알림 통합 프로젝트의 sms 알림 발송 서비스
Language: Go - Size: 130 KB - Last synced at: almost 2 years ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 1
robsonbittencourt/kafka-example
A small example of Kafka producer and consumer, based on Allura Apache Kafka Formation
Language: Kotlin - Size: 577 KB - Last synced at: about 2 months ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 0
bioyeneye/dotnetcore_kafka
Sample project to understand Kafka in dotnet core
Language: C# - Size: 10.7 KB - Last synced at: about 2 years ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 0
sumitaich1998/kafka-client
Simple app to demonstrate the Kafka Producer and Consumer client library.
Language: Java - Size: 150 KB - Last synced at: about 2 years ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 0
AdsulPri/apache-kafka
Basic setup of apache kafka
Size: 60.1 MB - Last synced at: about 2 years ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 0
xiaoxigua13437/springboot-kafka
Springboot整合flume，kafka
Language: Java - Size: 96.7 KB - Last synced at: about 2 years ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 0
sanjay035/E-Wallet-Service
The service helps in creating a user with e-wallet with some default balance, send money to other users, add money to the wallet, maintain transaction details and send an email notification whenever a transaction happens.
Language: Java - Size: 91.8 KB - Last synced at: over 1 year ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 4
bygui86/go-kafka-sarama
Sample GoLang project with Kafka
Language: Go - Size: 56.6 KB - Last synced at: 2 months ago - Pushed at: about 4 years ago - Stars: 2 - Forks: 1
rishabhverma17/kafka-producer-consumer-spring-boot
Kafka producer and consumer example using spring boot
Language: Java - Size: 57.6 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 6
PolukovY/email
Email service for send notification with nice template
Language: Java - Size: 85.9 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0
math-ferreira/apache-kafka-series
Projeto desenvolvido em Java, para consolidar conhecimentos adquiridos com o Kafka em curso realizado pela Udemy. Neste Projeto foi desenvolvido Productor e Consumer integrados com a API do Twitter
Language: Java - Size: 38.1 KB - Last synced at: about 2 months ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0
albeRoss/kafkapipeline
A data processing pipeline in Kafka that guarantees E2E exactly once semantics. Administrative scripts to deploy Kafka cluster on AWS.
Language: Java - Size: 182 KB - Last synced at: over 1 year ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0
Lokeshwaranramu/Netty-and-Kafka-Sending-Messages
Java Code for Sending Messages from kafka producer to consumer using netty server
Language: Java - Size: 24.4 KB - Last synced at: 5 months ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 1
fpaupier/notifyMask
Send an email notification to the system administrator upon consuming an alert message from a Kafka topic.
Language: Go - Size: 34.2 KB - Last synced at: 11 months ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0
satyampushkar/KafkaNetCore.OrderManager
Confluent.Kafka based .NET CORE API and worker service to mimic order processing to demonstrate KAFKA's Producer - Consumer functionality
Language: C# - Size: 8.79 KB - Last synced at: over 1 year ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0
pavdmyt/kafka-pg-upload
Kafka consumer + PosgreSQL producer
Language: Python - Size: 217 KB - Last synced at: 3 days ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0
harshit-budhraja/kafka_handler
A simple Kafka wrapper based on confluent_kafka python client.
Language: Python - Size: 26.4 KB - Last synced at: 10 days ago - Pushed at: almost 5 years ago - Stars: 2 - Forks: 0
kamon-io/kamon-kafka
Kamon Integration for Kafka(Producers|Consumers|Streams)
Language: Scala - Size: 194 KB - Last synced at: 21 days ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 3
it21208/Data_Engineer_Code_Challenge
𝐔𝐬𝐞𝐫𝐬 𝐨𝐟 𝐜𝐞𝐭𝐚𝐢𝐧 𝐨𝐫𝐠𝐚𝐧𝐢𝐬𝐚𝐭𝐢𝐨𝐧 𝐟𝐫𝐨𝐧𝐭-𝐟𝐚𝐜𝐢𝐧𝐠 𝐬𝐢𝐭𝐞 𝐬𝐞𝐞 𝐭𝐡𝐞 𝐜𝐥𝐚𝐬𝐬𝐢𝐟𝐢𝐞𝐝𝐬 𝐭𝐡𝐚𝐭 𝐚𝐫𝐞 𝐞𝐧𝐭𝐞𝐫𝐞𝐝 𝐢𝐧 𝐭𝐡𝐞 𝐬𝐲𝐬𝐭𝐞𝐦𝐬 𝐛𝐲 𝐭𝐡𝐞𝐢𝐫 𝐜𝐮𝐬𝐭𝐨𝐦𝐞𝐫𝐬. 𝐖𝐡𝐞𝐧 𝐚 𝐜𝐮𝐬𝐭𝐨𝐦𝐞𝐫 𝐜𝐫𝐞𝐚𝐭𝐞𝐬 𝐚 𝐜𝐥𝐚𝐬𝐬𝐢𝐟𝐢𝐞𝐝, 𝐭𝐡𝐞 𝐬𝐲𝐬𝐭𝐞𝐦𝐬 𝐞𝐦𝐢𝐭 𝐚 𝐫𝐞𝐜𝐨𝐫𝐝 𝐨𝐟 𝐢𝐭 𝐚𝐧𝐝 𝐩𝐮𝐛𝐥𝐢𝐬𝐡 𝐢𝐭 𝐭𝐨 𝐚 𝐊𝐚𝐟𝐤𝐚 𝐭𝐨𝐩𝐢𝐜. 𝟏. 𝐂𝐫𝐞𝐚𝐭𝐞 𝐚𝐧 𝐚𝐩𝐩𝐥𝐢𝐜𝐚𝐭𝐢𝐨𝐧 𝐭𝐡𝐚𝐭 𝐜𝐨𝐧𝐬𝐮𝐦𝐞𝐬 𝐭𝐡𝐞𝐬𝐞 𝐫𝐞𝐜𝐨𝐫𝐝𝐬. 𝟐. 𝐑𝐞𝐜𝐨𝐫𝐝 𝐭𝐡𝐞𝐦 𝐢𝐧 𝐚 𝐌𝐲𝐒𝐐𝐋 𝐝𝐚𝐭𝐚𝐛𝐚𝐬𝐞. 𝟑. 𝐖𝐫𝐢𝐭𝐞 𝐚 𝐒𝐐𝐋 𝐬𝐜𝐫𝐢𝐩𝐭 𝐭𝐨 𝐚𝐧𝐚𝐥𝐲𝐬𝐞 𝐭𝐡𝐢𝐬 𝐢𝐧𝐟𝐨𝐫𝐦𝐚𝐭𝐢𝐨𝐧.
Language: Python - Size: 113 KB - Last synced at: about 2 years ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 0
chidokun/kafka-consumer
Kafka Consumer sample for testing
Language: Java - Size: 57.6 KB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 2 - Forks: 1
virenukey/PythonKafkaElasticSearch
Sample project to integrate Kafka and Elastic Search using Python Flask
Language: Python - Size: 2.93 KB - Last synced at: 20 days ago - Pushed at: almost 6 years ago - Stars: 2 - Forks: 0
s-d-w/kafka-producer-consumer
A demo of a local Kafka cluster setup with a producer and consumer written with Spring Boot
Language: Java - Size: 69.3 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 2 - Forks: 1
canertosuner/kafka-producer-consumer
Language: C# - Size: 3.91 KB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 2 - Forks: 0
1337programming/kafka-node-wrapper
kafka node wrapper with a sample docker setup
Language: JavaScript - Size: 353 KB - Last synced at: about 2 months ago - Pushed at: over 6 years ago - Stars: 2 - Forks: 0
skroutz/rails-kafka-consumers
Companion source code to https://engineering.skroutz.gr/blog/kafka-rails-integration/
Language: Ruby - Size: 4.88 KB - Last synced at: about 2 months ago - Pushed at: about 7 years ago - Stars: 2 - Forks: 0
philipgold/kafka-spark-twitter-stream-demo
A demo project using Spark Streaming to analyze popular hashtags from the twitter data streams. The data comes from the Twitter Streaming API source and is fed to Kafka. The consumer service receives data from Kafka and then processes it in a stream using Spark Streaming.
Language: Java - Size: 148 KB - Last synced at: 12 months ago - Pushed at: about 7 years ago - Stars: 2 - Forks: 5
msales/archive-transporter 📦
Kafka consumer REST proxy
Language: Go - Size: 31.3 KB - Last synced at: 10 months ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 0
maninder-singh/socket-kafka-integration
socket.io with nodejs cluster module and integration with kafka and redis
Language: JavaScript - Size: 5.86 KB - Last synced at: about 2 years ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 1
AbhimanyuHK/Kafka-python
Language: Python - Size: 1000 Bytes - Last synced at: 2 months ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 0
abdheshkumar/kafka-kotlin-app
Kafka producer consumer app in kotlin
Language: Kotlin - Size: 275 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 1 - 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: 27 days ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0
JavaCoDED78/data-store-service
This application receives data from Data analyser service
Language: Java - Size: 76.2 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0
JavaCoDED78/data-analyser-service
This application receives data from Data producer service
Language: Java - Size: 95.7 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0
DiegoPorfirio01/chat
Pages Marketing SEO Friendly / Chat Realtime / Open API (SWAGGER)
Language: TypeScript - Size: 338 KB - Last synced at: 20 days ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0
rk8130/RealTimeIncrementalSync
RealTimeIncrementalSync is a real-time data streaming system that fetches product updates from a MySQL database, serializes the data in Avro format, and streams it to Kafka. Kafka consumers deserialize the data and append it to JSON files, enabling real-time monitoring and analysis of product information.
Language: Python - Size: 16.6 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 1 - Forks: 0
