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.1 MB - Last synced: about 4 hours ago - Pushed: about 5 hours ago - Stars: 305 - Forks: 60

gitmehedi/techstacks

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

Size: 31.4 MB - Last synced: about 9 hours ago - Pushed: about 10 hours ago - Stars: 3 - Forks: 0

euiyounghwang/python-platform-engine

python-platform-engine

Language: Ruby - Size: 352 MB - Last synced: about 13 hours ago - Pushed: about 14 hours ago - Stars: 0 - Forks: 0

razamehar/Financial-Stock-Analysis-and-Clustering

Analyzed 157 US Energy stocks (Jan-Dec '23), identified Bullish/Bearish trends and risk categories. Used KMeans, Hierarchical, Spectral Clustering, revealing balanced returns and low volatility. Integrated data with Kafka for seamless subscriptions.

Language: Jupyter Notebook - Size: 4.34 MB - Last synced: about 20 hours ago - Pushed: about 21 hours ago - Stars: 1 - Forks: 1

utair-digital/event-engine

Event engine - event driven framework

Language: Python - Size: 94.7 KB - Last synced: 1 day ago - Pushed: 1 day ago - Stars: 3 - Forks: 0

bersler/OpenLogReplicator

Open Source Oracle database CDC

Language: C++ - Size: 41.6 MB - Last synced: 1 day ago - Pushed: 1 day ago - Stars: 252 - Forks: 122

danielsobrado/CCDAK-Exam-Questions

Confluent Kafka questions to practice for CCDAK

Size: 249 KB - Last synced: 1 day ago - Pushed: 2 days ago - Stars: 1 - Forks: 0

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: 91.5 MB - Last synced: 1 day ago - Pushed: 2 days ago - Stars: 28 - Forks: 6

vepo/imersao-kafka

Curso básico sobre Apache Kafka

Language: Java - Size: 117 MB - Last synced: 2 days ago - Pushed: 3 days ago - Stars: 16 - Forks: 3

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

mookid8000/Topos

:cyclone: .NET Event Processing library

Language: C# - Size: 5.12 MB - Last synced: 4 days ago - Pushed: 4 days ago - Stars: 23 - Forks: 5

joker1007/embulk-output-kafka

Embulk output plugin for Apache Kafka

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

simPod/PhpKafka

PHP Kafka boilerplate wrapper around RdKafka

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

Computer-Network-Programming-Project/recommendation-engine

Generative AI & Recommendation Engine --- Firat University / Faculty of Technology / Software Engineering / Final Project

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

gui-meireles/fc2-kafka-advanced

Conceitos avançados do Kafka integrado com GoLang

Language: Go - Size: 150 KB - Last synced: 5 days ago - Pushed: 6 days ago - Stars: 0 - Forks: 0

eo-cqrs/eo-kafka

EO Kafka Producers and consumers for working with Apache Kafka message broker

Language: Java - Size: 1.24 MB - Last synced: 6 days ago - Pushed: 6 days ago - Stars: 26 - Forks: 3

dipjyotimetia/EventShark

Go kafka event streaming

Language: Go - Size: 281 KB - Last synced: 6 days ago - Pushed: 6 days ago - Stars: 0 - Forks: 0

emrealper/order-event-processing

This is an event-driven microservices architecture implementation running on docker containers.

Language: C# - Size: 955 KB - Last synced: 6 days ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

emrealper/event-driven-ordering

This is an event-driven microservices architecture implementation running on docker containers.

Language: C# - Size: 45 MB - Last synced: 6 days ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

senocak/Spring-Kotlin-Kafka-Producer-Consumer

Spring Kotlin Kafka Producer Consumer

Language: Kotlin - Size: 12.3 MB - Last synced: 7 days ago - Pushed: 4 months ago - Stars: 0 - 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: 318 KB - Last synced: 7 days ago - Pushed: 8 days ago - Stars: 50 - Forks: 3

zendesk/delivery_boy

A simple way to publish messages to Kafka from Ruby applications

Language: Ruby - Size: 128 KB - Last synced: 8 days ago - Pushed: 4 months ago - Stars: 236 - Forks: 41

strimzi/strimzi-kafka-bridge

An HTTP bridge for Apache Kafka®

Language: Java - Size: 2.43 MB - Last synced: 3 days ago - Pushed: 8 days ago - Stars: 263 - Forks: 117

gui-meireles/fc2-kafka-basic

Conceitos básicos do Kafka

Size: 11.7 KB - Last synced: 8 days ago - Pushed: 9 days ago - Stars: 0 - Forks: 0

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 MB - Last synced: 8 days ago - Pushed: 9 days ago - Stars: 6 - Forks: 0

FredrikMeyer/kafka-pi

Learn Kafka Streams by computing Pi

Language: Java - Size: 1.55 MB - Last synced: 9 days ago - Pushed: 9 days ago - Stars: 0 - Forks: 0

ashutoshsahoo/spring-boot-kafka

Spring boot application with Apache Kafka integration

Language: Java - Size: 8.79 KB - Last synced: 10 days ago - Pushed: about 4 years ago - Stars: 0 - Forks: 0

ashutoshsahoo/gs-spring-boot-kafka

Spring Boot Kafka Schema Registry

Language: Java - Size: 32.2 KB - Last synced: 10 days ago - Pushed: 7 months ago - Stars: 0 - Forks: 0

zhenik/kafka-apis-example

Presentation of different kafka apis

Language: Java - Size: 10.8 MB - Last synced: 10 days ago - Pushed: over 5 years ago - Stars: 0 - Forks: 0

kodtodya/kafkaSamples

Apache Kafka Client Examples

Language: Java - Size: 13.7 KB - Last synced: 10 days ago - Pushed: about 7 years ago - Stars: 1 - Forks: 0

kodtodya/kafka-beginner-sessions

This repository contains the Kafka Clients and broker configuration details and notes for beginner level

Language: Java - Size: 816 KB - Last synced: 10 days ago - Pushed: over 5 years ago - Stars: 0 - Forks: 0

kodtodya/apache-kafka-examples

This repository will have apache kafka with other technology demonstrations

Language: Java - Size: 24.3 MB - Last synced: 10 days ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

cmantas/kpipe

A simple script for repeating binary kafka messages from a server/stream to another

Language: Python - Size: 11.7 KB - Last synced: 10 days ago - Pushed: 8 months ago - Stars: 0 - Forks: 1

rollno748/di-kafkameter

JMeter Plugin to load test Apache Kafka topics/brokers

Language: Java - Size: 15.5 MB - Last synced: 10 days ago - Pushed: 10 months ago - Stars: 32 - Forks: 11

joowani/kq

Kafka-based Job Queue for Python

Language: Python - Size: 108 KB - Last synced: 3 days ago - Pushed: over 2 years ago - Stars: 572 - Forks: 24

abdheshkumar/kafka-kotlin-app

Kafka producer consumer app in kotlin

Language: Kotlin - Size: 257 KB - Last synced: 10 days ago - Pushed: 10 days ago - Stars: 1 - Forks: 0

confluentinc/librdkafka

The Apache Kafka C/C++ library

Language: C - Size: 30.6 MB - Last synced: 12 days ago - Pushed: 12 days ago - Stars: 7,297 - Forks: 3,109

scylladb/scylla-cdc-source-connector

A Kafka source connector capturing Scylla CDC changes

Language: Java - Size: 1.02 MB - Last synced: 11 days ago - Pushed: 11 days ago - Stars: 39 - Forks: 17

mikeroyal/Apache-Kafka-Guide

Apache Kafka Guide

Size: 203 KB - Last synced: 2 days ago - Pushed: over 2 years ago - Stars: 25 - Forks: 3

aws/go-kafka-event-source

Go/Kafka client library for developing event sourcing applications

Language: Go - Size: 298 KB - Last synced: 7 days ago - Pushed: 5 months ago - Stars: 13 - Forks: 4

se7enack/Easy-SSL-Kafka-for-K8S

Easy multi-node SSL Kafka for Kubernetes

Language: Shell - Size: 420 KB - Last synced: 14 days ago - Pushed: 14 days ago - Stars: 0 - Forks: 0

Liberxue/binlog-kafka-java

TiDB Binlog To Kafka Java SDK Support

Language: Java - Size: 37.1 KB - Last synced: 14 days ago - Pushed: over 4 years ago - Stars: 0 - Forks: 1

quantumbagel/PyAerial

PyAerial is scanning software for ADS-B in pure Python.

Language: Python - Size: 33.2 KB - Last synced: 14 days ago - Pushed: 15 days ago - Stars: 1 - Forks: 0

kafbat/kafka-ui

Open-Source Web UI for managing Apache Kafka clusters

Language: Java - Size: 33.8 MB - Last synced: 16 days ago - Pushed: 16 days ago - Stars: 305 - Forks: 14

SrinivasanTarget/python_flask_app

Sample Python Flask Application

Language: Python - Size: 7.81 KB - Last synced: 15 days ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

AbdelrhmanHamouda/springboot-kafka

Read README.md

Language: Java - Size: 78.1 KB - Last synced: 16 days ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

jjeanjacques10/alura-ecommerce-kafka

Aplicação desenvolvida na formação Kafka da Alura

Language: Java - Size: 114 KB - Last synced: 16 days ago - Pushed: over 2 years ago - Stars: 2 - Forks: 0

toniyanchev/kanafka-dotnet-storage-providers

Kanafka storage providers for .NET client

Language: C# - Size: 23.4 KB - Last synced: 17 days ago - Pushed: 17 days ago - Stars: 0 - Forks: 0

maciek1839/kafka-producer-consumer

Kafka producer and consumer samples

Language: Java - Size: 3.53 MB - Last synced: 17 days ago - Pushed: 17 days ago - Stars: 0 - Forks: 1

shahar0809/WikipediaStats

REST API that shows statistics of Wikipedia using Wikipedia Events and Kafka Streams

Language: Java - Size: 115 MB - Last synced: 17 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

hieuung/Streaming-Kafka

Using various data processing tool for real time data pipeline with Kafka

Language: Python - Size: 4.68 MB - Last synced: 17 days ago - Pushed: 17 days ago - Stars: 0 - 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: 18 days ago - Pushed: about 6 years ago - Stars: 2 - Forks: 5

mukul273/springboot-kafka-tutorial

springboot kafka tutorial

Language: Java - Size: 3.22 MB - Last synced: 18 days ago - Pushed: 18 days ago - Stars: 0 - Forks: 0

thiago-jv/SIS-PEDIDO-QUARKUS

Projeto utilizando java 17 com quarkus, panache-entity, panache-repository, restClient, fault tolerance, swagger api, profile, Cors, partner dto, mapstruts, customExceptionHandler, versionamento, lombok, rest-assured, junit, postgresql, REDIS, pg-admin, keycloak, rabbitmq, Kafka e docker compose.

Language: HTML - Size: 1.91 MB - Last synced: 18 days ago - Pushed: 18 days ago - Stars: 1 - Forks: 0

nomisRev/kotlin-kafka

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

Language: Kotlin - Size: 2.24 MB - Last synced: 15 days ago - Pushed: 15 days ago - Stars: 95 - Forks: 11

ealeykin/aspnetcorekafka 📦

A messaging infrastructure on top of Confluent.Kafka and AspNetCore

Language: C# - Size: 358 KB - Last synced: 19 days ago - Pushed: almost 2 years ago - Stars: 21 - Forks: 5

varunajmera0/apache-kafka

Apache Kafka

Language: Python - Size: 5.03 MB - Last synced: 20 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

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: 17 days ago - Pushed: 23 days ago - Stars: 2,368 - Forks: 291

cheryalabalram/spring-boot-kafka

Spring boot kafka ( v3.2.5 )which uses basic kafka configurations to enable the kafka functionality

Language: Java - Size: 5.86 KB - Last synced: 19 days ago - Pushed: 20 days ago - Stars: 0 - Forks: 0

assu10/kafka

kafka

Language: Java - Size: 78.1 KB - Last synced: 21 days ago - Pushed: 5 months ago - Stars: 0 - Forks: 0

shaikrasheed99/kotlin-ecommerce-microservices

Ecommerce Microservices application in Kotlin.

Language: Kotlin - Size: 1.81 MB - Last synced: 25 days ago - Pushed: 26 days ago - Stars: 0 - Forks: 0

tumanina/KafkaPlayground

Language: C# - Size: 11.7 KB - Last synced: 21 days ago - Pushed: 21 days ago - Stars: 0 - Forks: 0

karafka/karafka

Ruby and Rails efficient Kafka processing framework

Language: Ruby - Size: 5.08 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 1,965 - Forks: 166

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: 22 days ago - Pushed: 8 months ago - Stars: 3 - Forks: 0

hifly81/kafka-examples

Practical examples with Apache Kafka®

Language: Java - Size: 119 MB - Last synced: 22 days ago - Pushed: 22 days ago - Stars: 49 - Forks: 8

D3vKn1ght/learn-kafka

Learn Kafka with Golang and Python Examples

Language: Python - Size: 4.47 MB - Last synced: 22 days ago - Pushed: 22 days ago - Stars: 0 - Forks: 1

polarbeargo/nd064-c2-message-passing-projects-starter

Language: Python - Size: 2.61 MB - Last synced: 22 days ago - Pushed: 10 months ago - Stars: 0 - 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: 61.5 KB - Last synced: 23 days ago - Pushed: 23 days ago - Stars: 0 - Forks: 0

RajeshKancharapoo/KafkaMicroservices

Implementation of producer Microservice and consumer Microservice in Kafka

Language: Java - Size: 21.5 KB - Last synced: 23 days ago - Pushed: 23 days ago - Stars: 0 - Forks: 0

saabeilin/kafkian

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

Language: Python - Size: 115 KB - Last synced: 15 days ago - Pushed: 16 days ago - Stars: 28 - Forks: 3

harsh6768/kafka-fire

Everything related to KAFKA settingup,configuration, integration , scaling up

Language: JavaScript - Size: 5.59 MB - Last synced: 23 days ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0

SpringBootCourses/data-generator-microservice

This is data generator microservice for YouTube course.

Language: Java - Size: 55.7 KB - Last synced: 23 days ago - Pushed: 27 days ago - Stars: 16 - Forks: 3

giovannymassuia/distributed-ecommerce

Simple Micro Services Project with parts of an E-commerce to simulate a distributed system

Language: Java - Size: 128 KB - Last synced: 24 days ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

eccenca/cmem-plugin-kafka

This eccenca Corporate Memory plugin allows for sending and receiving messages from Apache Kafka.

Language: Python - Size: 792 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 0 - Forks: 0

JoelPintoMata/hello-apicurio

Apicurio - schema registry - Hello World

Language: Java - Size: 12.7 KB - Last synced: 26 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

PSSABISHEK/skoruz_analytics

Python scripts to handle data migration

Language: Python - Size: 188 KB - Last synced: 26 days ago - Pushed: over 4 years ago - Stars: 0 - Forks: 0

siddhantshar24/Real-Time-Kafka-Delivery-Tracking-API

A delivery application which uses the Kafka pub/sub model of sending messages.

Language: Java - Size: 66.4 KB - Last synced: 27 days ago - Pushed: 27 days ago - Stars: 1 - Forks: 0

thearyanahmed/ts-boilerplate

This is a boilerplate for using kafka. Serves RESTful apis with logging, support for configuration and .env, error handling and testsuite.

Language: TypeScript - Size: 11 MB - Last synced: 27 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

RaphaelManke/cdk-kafka-serverless

Example project for producing and consuming a aws msk serverless cluster with lambdas

Language: TypeScript - Size: 104 KB - Last synced: 27 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

zinzzas/kafka-producer

spring kafka producer

Language: Java - Size: 2.53 MB - Last synced: 28 days ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

THRUWOL/JavaRestApp_kafka-producer

Ковыряю разное

Language: Java - Size: 76.2 KB - Last synced: 27 days ago - Pushed: 28 days ago - Stars: 0 - Forks: 0

fgrosse/kafkactl

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

Language: Go - Size: 1.92 MB - Last synced: 28 days ago - Pushed: 28 days ago - Stars: 5 - Forks: 1

mktintumon/LocationUpdater-Kafka

Updates the Location of Driver in App using Kafka

Language: Java - Size: 63.5 KB - Last synced: 29 days ago - Pushed: 3 months ago - Stars: 0 - Forks: 0

paljsingh/community-discussion

Language: Python - Size: 12.4 MB - Last synced: 29 days ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

neo4j-contrib/neo4j-streams

Neo4j Kafka Connector

Language: Kotlin - Size: 3.55 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 167 - Forks: 67

Nasruddin/data-streaming-kafka-protobuf

Data streaming between Java and Golang service with Kafka using Protocol Buffers

Language: Java - Size: 67.4 KB - Last synced: 30 days ago - Pushed: over 1 year ago - Stars: 2 - Forks: 0

Nasruddin/KafkaStarter

Kafka Starter with Java Client

Language: Java - Size: 2.93 KB - Last synced: 30 days ago - Pushed: about 7 years ago - Stars: 1 - Forks: 0

ale-fuentes-ar/tutorial-kafka-withcsharp

This tutorial is a simple use of Kafka with C#. Also use Docker file for create a container Kafka for testing my tutorial.

Language: C# - Size: 3.91 KB - Last synced: 30 days ago - Pushed: 9 months ago - Stars: 0 - Forks: 0

NikitaBuffy/orders-kafka

A test project demonstrating the use of Apache Kafka, simulating the operation of an online store.

Language: Java - Size: 498 KB - Last synced: 30 days ago - Pushed: 7 months ago - Stars: 0 - Forks: 0

javaHelper/Kafka-Streams-with-Spring-Cloud-Stream

Oreilly - Kafka Streams with Spring Cloud Stream

Language: Java - Size: 210 KB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

eltonsandre/intellij-kafka

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

Size: 2.91 MB - Last synced: about 1 month ago - Pushed: 10 months ago - Stars: 0 - Forks: 0

neerazz/spring-boot-kafka-poc

Language: Java - Size: 96.7 KB - Last synced: about 1 month ago - Pushed: almost 4 years ago - Stars: 1 - Forks: 0

jmahmood/kafkasnake

A set of examples of how to use Heroku Kafka with Python on your local environment

Language: Python - Size: 7.81 KB - Last synced: about 1 month ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0

andrewinci/rap

RAP is a fast Avro generator + Kafka producer that allows to fully control the data generation via a simple yaml configurations.

Language: Go - Size: 67.4 KB - Last synced: about 1 month ago - Pushed: 5 months ago - Stars: 0 - Forks: 0

hossensyedriadh/spring-boot-kafka-demo

Basic demonstration of Apache Kafka message producer and consumer applications built with Java and Spring Boot

Language: Java - Size: 73.2 KB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0

yangboz/spring-boot-kafka-restful-swagger

A SpringBoot RESTful, SwaggerUI API documentation example for Kafka.

Language: Java - Size: 37.5 MB - Last synced: about 1 month ago - Pushed: over 5 years ago - Stars: 1 - Forks: 1

Telefonica/prometheus-kafka-adapter

Use Kafka as a remote storage database for Prometheus (remote write only)

Language: Go - Size: 30.4 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 347 - Forks: 134

loicgreffier/spring-boot-kafka-quickstarts

Code samples around Spring Boot and Kafka.

Language: Java - Size: 22.4 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 9 - Forks: 4

ess-dmsc/event-formation-unit

Implementation of neutron event formation pipeline for ESS

Language: C++ - Size: 42.2 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 9 - Forks: 6

karafka/karafka-web

Web UI for monitoring and managing Karafka consumers

Language: Ruby - Size: 977 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 45 - Forks: 6