Most popular kafka repositories and open source projects

bigdata_practice TurboWay Python

大数据分析可视化实践

278 50 278

dagger raystack Java

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming...

278 41 278

kroxylicious kroxylicious Java

Kroxylicious, the snappy open source proxy for Apache Kafka®

276 104 276

oura txpipe Rust

The tail of Cardano

276 79 276

docker-compose-stacks ninadingole Shell

Contains all the docker-compose stacks I use for my testing and development work

276 126 276

smallrye-reactive-messaging smallrye Java

SmallRye Reactive Messaging

274 198 274

waterdrop karafka Ruby

Standalone Karafka library for producing Kafka messages

273 41 273

old-argo-dataflow argoproj-labs Go

Dataflow is a Kubernetes-native platform for executing large parallel data-processing pipelines.

271 28 271

kafka-streams-in-action bbejeck Java

Source code for the Kafka Streams in Action Book

269 179 269

kafka-tutorials confluentinc Java

Tutorials and Recipes for Apache Kafka

269 92 269

voik marceloboeira Rust

♒︎ [WIP] An experimental ~distributed~ commit-log

263 24 263

microservice-scaffold jackson-zb Java

基于Spring Cloud（Greenwich.SR2）搭建的微服务脚手架（适用于在线系统），已集成注册中心（Nacos Config）、配置中心（Nacos Discovery）、认证授权（Oauth 2...

259 65 259

srclient riferrei Go

Golang Client for Schema Registry

258 79 258

confluent-kafka-dotnet confluentinc C#

Confluent's Apache Kafka .NET client

257 896 257

hsweb-iot-cloud hs-web JavaScript

本项目已迁移至 github.com/jetlinks

254 125 254

recommendSys jasonTangxd Java

推荐项目（实时推荐和离线推荐）

254 116 254

moon aide-family Go

Moon is a versatile monitoring and alerting platform designed for multiple domains, supporting various application scenarios such as cloud-native, Int...

252 62 252

dotnet-new-caju ivanpaulovich C#

Learn Clean Architecture with .NET Core 3.0 :fire:

251 33 251

gimel paypal Scala

Big Data Processing Framework - Unified Data API or SQL on Any Storage

251 81 251

gosiris teivah Go

An actor framework for Go

250 22 250

astra slackhq Java

Astra is a structured log search and analytics engine developed by Slack and Salesforce

250 44 250

yivnet yiv Go

Yivnet is a microservice game server base on go-kit

249 63 249

broadway_kafka dashbitco Elixir

A Broadway connector for Kafka

249 55 249

azure-event-hubs-for-kafka Azure Java

Azure Event Hubs for Apache Kafka Ecosystems

246 214 246

Go-CQRS-Kafka-gRPC-Microservices AleksK1NG Go

Go gRPC Kafka CQRS microservices with tracing

244 68 244

ABRiS AbsaOSS Scala

Avro SerDe for Apache Spark structured APIs.

243 83 243

kafka-health-check andreas-schroeder Go

Health Check for Kafka Brokers.

242 82 242

laravel-queue php-enqueue PHP

Laravel Enqueue message queue extension. Supports AMQP, Amazon SQS, Kafka, Google PubSub, Redis, STOMP, Gearman, Beanstalk and others

241 48 241

liiklus bsideup Java

Reactive (RSocket/gRPC) Gateway for the event-based systems

239 35 239

operators kudobuilder Shell

Collection of Kubernetes Operators built with KUDO.

238 77 238

azure-event-hubs-spark Azure Scala

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

238 179 238

kafka-connect-storage-cloud confluentinc Java

Kafka Connect suite of connectors for Cloud storage (Amazon S3)

237 302 237

delivery_boy zendesk Ruby

A simple way to publish messages to Kafka from Ruby applications

236 36 236

kafka-spring-boot-example thepracticaldeveloper Java

Spring Boot application showing basic configuration to work with Kafka

232 115 232

workflow luno Go

The type-safe, event-driven workflow orchestration library that scales with your business. Build robust, distributed workflows in Go with compile-time...

231 19 231

Drain3 logpai Python

Drain log template miner in Python3

228 77 228

tiered-storage-for-apache-kafka Aiven-Open Java

RemoteStorageManager for Apache Kafka® Tiered Storage

225 49 225

kafka-client uber-go Go

Go client library for Apache Kafka

223 28 223

kafka-view fede1024 Rust

Kafka web UI

223 31 223

amazonriver hellobike Go

amazonriver 是一个将postgresql的实时数据同步到es或kafka的服务

222 59 222

kcli cswank Go

A kafka command line browser

222 17 222

kcl twmb Go

Your one stop shop to do anything with Kafka. Producing, consuming, transacting, administrating; 0.8.0 through 4.2+

222 23 222

Thunder Nepxion Java

⚡️ Nepxion Thunder is a distribution RPC framework based on Netty + Hessian + Kafka + ActiveMQ + Tibco + Zookeeper + Redis + Spring Web MVC + Spring...

220 87 220