Topic

kafka

Repositories (1207)

wirbelsturm
wirbelsturm miguno Shell

[PROJECT IS NO LONGER MAINTAINED] Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big...

332
sdk-java
sdk-java cloudevents Java

Java SDK for CloudEvents

332
trubka
trubka xitonix Go

A CLI tool for Kafka

330
distributed_framework
distributed_framework ydf0509 Python

pip install function_scheduling_distributed_framework,python通用分布式函数调度框架。python万能超高并发神器,改成funboost框架名字,停止更新,只更新fun...

326
every-single-day-i-tldr
every-single-day-i-tldr sderosiaux

A daily digest of the articles or videos I've found interesting, that I want to share with you.

322
blog
blog hhstore

My Tech Blog: about Mojo / Rust / Golang / Python / Kotlin / Flutter / VueJS / Blockchain etc.

322
fw-spring-cloud
fw-spring-cloud xuyisu Java

SpringCloud构建实战、从入门到高级,包含eureka、zuul、gateway、feign、ribbon、hystrix、mq、turbine、nacos、elk、consul、zookeeper、rocketmq、kafka、分...

320
digital-restaurant
digital-restaurant idugalic Kotlin

DDD. Event sourcing. CQRS. REST. Modular. Microservices. Kotlin. Spring. Axon platform. Apache Kafka. RabbitMQ

318
benchmark
benchmark openmessaging Java

OpenMessaging Benchmark Framework

318
GameServer4j
GameServer4j jzyong Java

Distributed Java game server, including login, gateway, game demo

311
video-stream-analytics
video-stream-analytics baghelamit Java
309
streamify
streamify ankurchavda Python

A data engineering project with Kafka, Spark Streaming, dbt, Docker, Airflow, Terraform, GCP and much more!

308
strimzi-kafka-bridge
strimzi-kafka-bridge strimzi Java

An HTTP bridge for Apache Kafka®

307
data-accelerator
data-accelerator microsoft C#

Data Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, edit...

305
springwolf-core
springwolf-core springwolf Java

Automated documentation for event-driven applications built with Spring Boot

305
taotao-cloud-project
taotao-cloud-project shuigedeng Java

taotao-cloud (taotao云平台) 基于gradle9.1.0、jdk25, 支持graalvm25, 采用最新的spring 6.2.11、SpringBoot 3.5.6、SpringCloud 2025.0.0、SpringSecurity 6.5...

305
karapace
karapace aiven HTML

Karapace - Your Apache Kafka® essentials in one tool

305
cqrs-manager-for-distributed-reactive-services
cqrs-manager-for-distributed-reactive-services capitalone Java

Experimental CQRS and Event Sourcing service

303
prometheus-kafka-adapter
prometheus-kafka-adapter Telefonica Go

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

300
kafka-operator
kafka-operator krallistic Go

A Kafka Operator for Kubernetes

298
Hummingbird
Hummingbird guoming C#

分布式锁,分布式ID,分布式消息队列、配置中心、注册中心、服务注册发现、超时、重试、熔断、负载均衡

298
kafka-cheat-sheet
kafka-cheat-sheet lensesio

Curated by Lenses.io

297
mongo-kafka
mongo-kafka mongodb Java

MongoDB Kafka Connector

297
intents-operator
intents-operator otterize Go

Manage network policies, AWS, GCP & Azure IAM policies, Istio Authorization Policies, and Kafka ACLs in a Kubernetes cluster with ease.

296
scalatest-embedded-kafka
scalatest-embedded-kafka manub Scala

A library that provides an in-memory Kafka instance to run your tests against.

294
fluent-plugin-kafka
fluent-plugin-kafka fluent Ruby

Kafka input and output plugin for Fluentd

294
kafkastreams-cep
kafkastreams-cep fhussonnois Java

Complex Event Processing on top of Kafka Streams

293
node-sinek
node-sinek nodefluent TypeScript

:tophat: Most advanced high level Node.js Kafka client

291
qbusbridge
qbusbridge Qihoo360 C++

The Apache Kafka Client SDK

288
kafka-gitops
kafka-gitops devshawn Java

🚀Manage Apache Kafka topics and generate ACLs through a desired state file.

287
kouncil
kouncil Consdata TypeScript

Powerful dashboard for your Kafka. Monitor status, manage groups, topics, send messages and diagnose problems. All in one user friendly web dashboard.

285
decaton
decaton line Java

High throughput asynchronous task processing on Apache Kafka

285
stove
stove Trendyol Kotlin

Stove: The easiest way of writing e2e/component tests for your JVM back-end app with Kotlin

284
goflow2
goflow2 netsampler Go

High performance sFlow/IPFIX/NetFlow Collector

284
divolte-collector
divolte-collector divolte Java

Divolte Collector

283
clickhouse-sink-connector
clickhouse-sink-connector Altinity Python

Replicate data from MySQL, Postgres and MongoDB to ClickHouse®

283
syncClient
syncClient sasou Java

syncClient,数据实时同步中间件(同步mysql到kafka、redis、elasticsearch、httpmq)!

280
ksql-udf-deep-learning-mqtt-iot
ksql-udf-deep-learning-mqtt-iot kaiwaehner Java

Deep Learning UDF for KSQL for Streaming Anomaly Detection of MQTT IoT Sensor Data

275
Pos
Pos NHadi JavaScript

Sample Application DDD, Reactive Microservices, CQRS Event Sourcing Powered by DERMAYON LIBRARY

275
conduit
conduit ConduitIO Go

Conduit streams data between data stores. Kafka Connect replacement. No JVM required.

274
zoe
zoe adevinta Kotlin

The Kafka CLI for humans

272
docker-compose-stacks
docker-compose-stacks ninadingole Shell

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

272
kafka-tutorials
kafka-tutorials confluentinc Java

Tutorials and Recipes for Apache Kafka

269
old-argo-dataflow
old-argo-dataflow argoproj-labs Go

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

268
kafka-connect-file-pulse
kafka-connect-file-pulse streamthoughts Java

🔗 A multipurpose Kafka Connect connector that makes it easy to parse, transform and stream any file, in any format, into Apache Kafka

268
rdkafka-ruby
rdkafka-ruby appsignal Ruby

Modern and performant Kafka client library for Ruby based on librdkafka

267
oura
oura txpipe Rust

The tail of Cardano

267
ecommerce-microservice-backend-app
ecommerce-microservice-backend-app SelimHorri Java

Spring Boot microservices app with Spring Cloud, Robust and resilient backend managing e-Commerce app

266
modern-cpp-kafka
modern-cpp-kafka morganstanley C++

A C++ API for Kafka clients (i.e. KafkaProducer, KafkaConsumer, AdminClient)

264
voik
voik marceloboeira Rust

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

263