1.apache / kafka
Apache Kafka - A distributed event streaming platform
Ranked by Attention Score: stars gained over the last 180 complete days
24 repositories by Attention Score · May 7, 2026 – Nov 2, 2026 (UTC)
Apache Kafka - A distributed event streaming platform
Diskless Kafka® on S3. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency. Multi-AZ Availability.
🦎 A lightweight, streaming-native, multi-protocol gateway for AI, APIs, and real-time data. Route LLM requests across providers, govern MCP tools, and connect Kafka, MQTT, and HTTP through one high-performance engine with shared security and observability.
Change data capture for a variety of databases. Please log issues at https://github.com/debezium/dbz/issues.
Open-Source Web UI for Apache Kafka Management
大数据入门指南 :star:
一个涵盖六个专栏:Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖,右上角来个 Star,感恩 1024
Apache Camel is an open source integration framework with 350+ connectors. Write routes in Java, YAML, or XML. Run on Spring Boot, Quarkus, or standalone. Apache License 2.0.
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
📌 异步线程池框架,支持线程池动态变更&监控&报警,无需修改代码轻松引入。Asynchronous thread pool framework, support Thread Pool Dynamic Change & monitoring & Alarm, no need to modify the code easily introduced.
The ultimate distributed MQTT broker. Handles 100M+ connections and 10M msg/sec with ease. Built on Kafka to provide industrial-grade persistence and eliminate data loss.
Kroxylicious, the snappy open source proxy for Apache Kafka®
Confluent Schema Registry for Kafka
Fast and reliable message broker built on top of Kafka.
zerocode-tdd is a community-developed, free, open-source, outcome-driven automated testing framework for Data Pipelines, ETL, REST API, Kafka(Data Streams), Databases and Load scenarios. all defined in simple JSON or YAML — with zero coding.
The database purpose-built for stream processing applications.
An extensible distributed system for reliable nearline data streaming at scale
An HTTP bridge for Apache Kafka®
Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.
Java SDK for CloudEvents
Secor is a service implementing Kafka log persistence
Oryx 2: Lambda architecture on Apache Spark, Apache Kafka for real-time large scale machine learning
A distributed event bus that implements a RESTful API abstraction on top of Kafka-like queues
Distributed Stream and Batch Processing