Ranked by Attention Score: stars gained over the last 30 complete days
80 repositories by Attention Score · Oct 4, 2026 – Nov 2, 2026 (UTC)
Orchestrate everything, everywhere. The open-source control plane for workflows across data, infrastructure, business processes and AI agents. Declarative YAML, event-driven, any language, Git-versioned, scalable to millions of executions.
Apache Kafka - A distributed event streaming platform
mall项目是一套电商系统，包括前台商城系统及后台管理系统，基于Spring Boot+MyBatis实现，采用Docker容器化部署。 前台商城系统包含首页门户、商品推荐、商品搜索、商品展示、购物车、订单流程、会员中心、客户服务、帮助中心等模块。 后台管理系统包含商品管理、订单管理、会员管理、促销管理、运营管理、内容管理、统计报表、财务管理、权限管理、设置等模块。
Apache Doris is a real-time analytics and hybrid search database for AI agents.
All-in-one IoT Platform - Device management, data collection, processing and visualization.
World's most powerful open data catalog for building a high-performance, geo-distributed and federated metadata lake.
Change data capture for a variety of databases. Please log issues at https://github.com/debezium/dbz/issues.
SeaTunnel is a multimodal, high-performance, distributed, massive data integration tool.
Official repository of Trino, the distributed SQL query engine for big data, formerly known as PrestoSQL (https://trino.io)
😮 Core Interview Questions & Answers For Experienced Java(Backend) Developers | 互联网 Java 工程师进阶知识完全扫盲：涵盖高并发、分布式、高可用、微服务、海量数据处理等领域知识
QuestDB is a high performance, open-source, time-series database
The world's fastest open query engine for sub-second analytics both on and off the data lakehouse. With the flexibility to support nearly any scenario, StarRocks provides best-in-class performance for multi-dimensional analytics, real-time analytics, and ad-hoc queries. A Linux Foundation project.
Upserts, Deletes And Incremental Processing on Big Data.
mall-swarm是一套微服务商城系统，采用了 Spring Cloud Alibaba、Spring Boot 3.5、Sa-Token、MyBatis、Elasticsearch、Docker、Kubernetes等核心技术，同时提供了基于Vue的管理后台方便快速搭建系统。mall-swarm在电商业务的基础集成了注册中心、配置中心、监控中心、网关等系统功能。
Apache DolphinScheduler is the modern data orchestration platform. Agile to create high performance workflow with low-code
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.
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
大数据入门指南 :star:
Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
Redisson: Valkey & Redis Java Client and Real-Time Data Platform. Sync/Async/RxJava/Reactive API. Extends Valkey and Redis with over 60 objects and services: Set, Multimap, SortedSet, Map, List, Queue, Deque, Semaphore, Lock, AtomicLong, Map Reduce, Bloom filter, Spring, Tomcat, Scheduler, JCache API, Hibernate, RPC, local cache..
Apache Beam is a unified programming model for Batch and Streaming data processing.
mall学习教程，架构、业务、技术要点全方位解析。mall项目（60k+star）是一套电商系统，使用现阶段主流技术实现。涵盖了SpringBoot、MyBatis、Elasticsearch、RabbitMQ、Redis、MongoDB、MySQL等技术，采用Docker容器化部署。
Open-Source Web UI for Apache Kafka Management
Apache Pulsar - distributed pub-sub messaging system
Empowering Data Intelligence with Distributed SQL for Sharding, Scalability, and Security Across All Databases.
一个涵盖六个专栏：Spring Boot 2.X、Spring Cloud、Spring Cloud Alibaba、Dubbo、分布式消息队列、分布式事务的仓库。希望胖友小手一抖，右上角来个 Star，感恩 1024
The open source, cloud native tool for API Mocking and Testing. Microcks is a Cloud Native Computing Foundation incubating project 🚀
Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
The official home of the Presto distributed SQL query engine for big data
A better compressed bitset in Java: used by Apache Spark, Netflix Atlas, Apache Pinot, Tablesaw, and many others
Pentaho Data Integration ( ETL ) a.k.a Kettle
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
🏆 Real-Time no-code, powerful and secure ORM 🚀 providing APIs and Docs without coding by Backend, and Frontend(Client) can customize response JSONs 🏆 实时 零代码、全功能、强安全 ORM 库 🚀 后端接口和文档零代码，前端(客户端) 定制返回 JSON 的数据和结构
Apache Ignite
Micro second messaging that stores everything to disk
DataSphereStudio is a one stop data application development& management portal, covering scenarios including data exchange, desensitization/cleansing, analysis/mining, quality measurement, visualization, and task scheduling.
A graph database that supports more than 100+ billion data, high performance and scalability (Include OLTP Engine & REST-API & Backends)
Nessie: Transactional Catalog for Data Lakes with Git-like semantics
Suite of tools for deploying and training deep learning models using the JVM. Highlights include model import for keras, tensorflow, and onnx/pytorch, a modular and tiny c++ library for running math code and a java based math library on top of the core c++ library. Also includes samediff: a pytorch/tensorflow like library for running deep learn...
Maxwell's daemon, a mysql-to-json kafka producer
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.
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
Apache Linkis builds a computation middleware layer to facilitate connection, governance and orchestration between the upper applications and the underlying data engines.
Confluent Schema Registry for Kafka
An open source, a high-performance hybrid integration platform that allows developers quick integration with any application, data, or system.
JeroMQ is a pure Java implementation of the ZeroMQ messaging library, offering high-performance asynchronous messaging for distributed or concurrent applications.
Distributed Big Data Orchestration Service
EventMesh is a new generation serverless event middleware for building distributed event-driven applications.
Elassandra = Elasticsearch + Apache Cassandra
Hopsworks - Data-Intensive AI platform with a Feature Store
Framework for building Event-Driven Microservices
An extensible distributed system for reliable nearline data streaming at scale
A large-scale entity and relation database supporting aggregation of properties
Stream Processing and Complex Event Processing Engine
SQL-based streaming analytics platform 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.
An HTTP bridge for Apache Kafka®
Apache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter
An easy-to-use BI server built for SQL lovers. Power data analysis in SQL and gain faster business insights.
JVM Profiler Sending Metrics to Kafka, Console Output or Custom Reporter
Distributed Stream and Batch Processing
The MongoDB Spark Connector
Microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. It features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing
An extensible Java framework for building event-driven applications that break up XML and non-XML data into chunks for data integration
LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents
The database purpose-built for stream processing applications.
Emissary is simple, yet 🗲FAST🗲 messaging library for decoupling messages (requests and events) and message handlers 🚀
Ballerina MQTT Module.