#kafka

Java SDK for CloudEvents

Distributed job scheduler & Orchestrator on your infrastructure

🦀 Krafka - A pure Rust, async-native Apache Kafka client designed for high performance, safety, and ease of use.

Open Platform for Richful API's

C++ Parallel Computing and Asynchronous Networking Framework

Cron based Kafka exception consumer with the power of auto retry & concurrency

A bundle of opinionated Apache Kafka / Confluent Schema Registry helpers

Useful utilities, interfaces and base classes for message queue handling

Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go.

A Ruby client library for Apache Kafka

Apache Kafka client library for Erlang/Elixir

High throughput asynchronous task processing on Apache Kafka

No repository description published.

Kafka library in Go

taotao-cloud (taotao云平台)是一个企业级单体架构和微服务架构的快速开发脚手架。提供多种便捷starter进行功能扩展，采用DDD(领域驱动设计)思想，快速搭建企业级系统。基于gradle9.8.1、jdk25,、spring7.0.9、SpringBoot4.1.1、SpringCloud2025.1.3、SpringCloudAlibaba2025.1.0.0、SpringSecurity7.1.1、Mybatis-Plus3.5.16等开发的微服务开发脚手架，包括中间件模块、大数据模块、微服务业务模块、前端模块提供技术框架的基础能力的封装，减少开发工作，只关注业务,包含了工作以来的工作总结和技术沉淀。

collection of production-ready modules. 50% vibe coded

Composable Kafka consumer library for building modular, testable JVM data pipelines.

Production-ready, stable Kafka client for PHP

Declarative ETL framework for YAML-driven data pipelines

Kafka wire protocol broker in a single Go binary. Consumer groups, SASL, TLS, ACLs, Prometheus, S3 tiering. Runs anywhere Docker runs.

imi 是一款支持长连接微服务分布式的 PHP 开发框架，它可以运行在 PHP-FPM、Swoole、Workerman、RoadRunner 等多种容器环境下。它支持 HttpApi、WebSocket、TCP、UDP、MQTT 服务的开发。特别适合互联网微服务、即时通讯聊天im、物联网等场景！QQ群：17916227

Kubernetes service bindings utility

High-performance, streaming data pipelines for .NET

Terraform Kafka Provider

Production intelligence layer for feature flags at scale — blast radius gating, circuit-breaker auto-rollback, Merkle-linked audit log, incident correlation, and Knight Capital–style tombstoning. Go + Python + TypeScript polyglot monorepo.

Create an executable project (API and Admin App) from a database or natural language prompt with 1 command, customize with declarative rules and Python in your IDE, containerize and deploy.

An Avro Library that emphasizes testability and ease of use.

Python library for practicing the event sourcing pattern using DDD

Conduit connector for Apache Kafka

Kafka Implementation