1.apache / kafka
Apache Kafka - A distributed event streaming platform
Ranked by Attention Score: stars gained over the last 30 complete days
19 repositories by Attention Score · Oct 4, 2026 – Nov 2, 2026 (UTC)
Apache Kafka - A distributed event streaming platform
Change data capture for a variety of databases. Please log issues at https://github.com/debezium/dbz/issues.
Diskless Kafka® on S3. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency. Multi-AZ Availability.
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.
大数据入门指南 :star:
Open-Source Web UI for Apache Kafka Management
一个涵盖六个专栏:Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖,右上角来个 Star,感恩 1024
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Kroxylicious, the snappy open source proxy for Apache Kafka®
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.
📌 异步线程池框架,支持线程池动态变更&监控&报警,无需修改代码轻松引入。Asynchronous thread pool framework, support Thread Pool Dynamic Change & monitoring & Alarm, no need to modify the code easily introduced.
Confluent Schema Registry for Kafka
An extensible distributed system for reliable nearline data streaming at scale
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.
Fast and reliable message broker built on top of Kafka.
Java SDK for CloudEvents
An HTTP bridge for Apache Kafka®
Distributed Stream and Batch Processing
The database purpose-built for stream processing applications.