Most popular kafka repositories and open source projects

hotdog buoyant-data Rust

Hotdog is a syslog-to-Kafka forwarder which aims to get log entries into Apache Kafka as quickly as possible.

48 7 2

MCard DuHouAn Java

:credit_card:优惠券系统后台实现

48 11 2

tipoca-stream practo Go

Near real time cloud native data pipeline in AWS (CDC+Sink). Hosts code for RedshiftSink. RDS to RedshiftSink Pipeline with masking and reloading supp...

48 4 24

eCupcakesFactoryOnContainers srigumm JavaScript

"eCupcakesFactoryOnContainers" is based on a simplified "Microservices" architecture and docker containers. Core intent of this reference application...

48 29 5

secret-provider lensesio Scala

Open Source Secret Provider plugin for the Kafka Connect framework

48 37 16

netcore-microservices patrikduch C#

Example of production-ready microservices written in modern .NET

48 24 4

Kaffee oslabs-beta Java

Java Management Extension Client for Monitoring Kafka Metrics

48 4 2

go-microservice-template infranyx Go

Golang Microservice Template, is a simple boilerplate for golang applications. Protohub Template of this repository is https://github.com/infranyx/pro...

48 1 0

spring-chatting-server ghkdqhrbals Java

In this project, we develop a chat server with automatic distribution, automatic scale in/out, and maintenance functions! For more information, please...

48 4 2

learn-you-some-kafka FundingCircle Ruby

Atomic, bite-size, highly-focused interactive tutorials that teach you how to work with Kafka

47 2 47

BigData-Learning josonle

大数据学习，主要涉及Kafka、ZooKeeper、Hive、HBase、Spark

47 29 3

kafka-experiment joynal JavaScript

Apache kafka message queue experiment with nodejs

47 9 3

hyperdrive AbsaOSS Scala

Extensible streaming ingestion pipeline on top of Apache Spark

47 14 10

explore-flink felipegutierrez Java

This project uses Apache Flink as a stream engine that consumes data from the File system or Kafka brokers and exposes metrics using Prometheus and Gr...

47 23 2

hercules vostok Java

Vostok Hercules is an open-source distributed system based on Apache Kafka and used for reliable delivery of telemetry data from microservices to stor...

47 9 14

motornet GDATASoftwareAG C#

Motor.NET is a microservice framework based on Microsoft.Extensions.Hosting

47 10 9

go-graphql-subscription-example ccamel Go

☝️ go-graphql subscription over Kafka/Redis/NSQ example

47 5 3

Kafka-Example muhammedsedef Java

Kafka Example

47 5 1

di-kafkameter rollno748 Java

JMeter Plugin to load test Apache Kafka topics/brokers

47 13 3

py-avro-schema jpmorganchase Python

Generate Apache Avro schemas for Python types including standard library data-classes and Pydantic data models.

47 15 2

Advanced-Data-Engineering-with-Databricks santiagortiiz Python

Databricks. Incremental data processing, task orchestration, and production job monitoring.

47 65 2

flink-demos jaehyeon-kim Python

Apache Flink Demo Projects

47 15 2

Real-Time-Twitter-Sentiment-Analysis drisskhattabi6 Jupyter Notebook

This repo contains Big Data Project, its about "Real Time Twitter Sentiment Analysis via Kafka, Spark Streaming, MongoDB and Django Dashboard".

47 12 2

atleon atleon Java

Lightweight infinite reactive stream processing framework

47 7 2

fdp-modelserver typesafehub Scala

An umbrella project for multiple implementations of model serving

46 20 11

scrapy-kafka-redis tenlee2012 Python

Distributed crawling/scraping, Kafka And Redis based components for Scrapy

46 13 2

burrow-kafka-dashboard ignatev

Kubernetes Kafka Overview, Burrow consumer lag stats, Kafka disk usage

46 12 5

core-legacy inspr Go

Inspr is an agnostic application mesh for simpler, faster, and securer development of distributed applications (dApps).

46 3 1

kafka-connectors renrenche Java

kafka connector 插件，支持输入 mysql binlog 和 json 格式写入ClickHouse。持续更新

46 24 8

cl-rdkafka SahilKang Common Lisp

Common Lisp library for Kafka

46 8 4

tamer laserdisc-io Scala

Standalone alternatives to Kafka Connect Connectors

46 15 5

skafka evolution-gaming Scala

Scala wrapper for kafka consumer and producer

46 19 13

bobbycar sa-mw-dach HTML

IoT Transportation demo using Red Hat OpenShift and Middleware technologies

46 28 13

nccommunity LanjunC Java

基于SSM + Spring Boot + Thymeleaf开发的论坛社区网站

46 11 1

kafkalerts oslabs-beta JavaScript

Open source, accessibility driven web application for monitoring and alerting Apache Kafka broker metrics

46 4 2

amazon-msk-java-app-cdk aws-samples Java

This project provides and example of end to end data processing application created using the combination of Amazon Managed Streaming for Apache Kafka...

46 21 5

BigData wzqwtt Java

小白大数据学习笔记 :star:

46 8 1

UE-EasyKafka sha3sha3 C++

EasyKafka is a Kafka/Redpanda client sub-system for unreal engine. It supports producing and consuming records through blueprint and C++.

46 11 1

redis-kafka-connect redis-field-engineering Java

Redis Kafka Connector (Source and Sink) by Redis

46 38 4

provider-kafka crossplane-contrib Go

Crossplane provider for Kafka

46 45 11

emqx-kafka-bridge iotblue Erlang

EMQX plugin Kafka bridge send messgaes from broker to kafka

45 29 45

mod_event_kafka voiceip C++

Freeswitch Kafka Plugin

45 33 6

Farseer.Net FarseerNet C#

Provides consistent standard use of common components of the .Net Core language

45 11 5

Kafka-Sonar oslabs-beta TypeScript

The one-stop shop Docker Desktop Extension for seamless Kafka cluster monitoring and troubleshooting 🐋 🚀

45 5 3

plumber RPG-18 C++

Simple desktop application for Apache Kafka

45 4 3

RealtimeStreamingEngineering airscholar Python

This project serves as a comprehensive guide to building an end-to-end data engineering pipeline using TCP/IP Socket, Apache Spark, OpenAI LLM, Kafka...

45 31 2