Ranked by Attention Score: stars gained over the last 90 complete days
82 repositories by Attention Score · Aug 6, 2026 – Nov 3, 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
Diskless Kafka® on S3. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency. Multi-AZ Availability.
All-in-one IoT Platform - Device management, data collection, processing and visualization.
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.
World's most powerful open data catalog for building a high-performance, geo-distributed and federated metadata lake.
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
Apache DolphinScheduler is the modern data orchestration platform. Agile to create high performance workflow with low-code
Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
Upserts, Deletes And Incremental Processing on Big Data.
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.
TranslatedDataX is the open-source version of Alibaba Cloud DataWorks Data Integration.
Open-Source Web UI for Apache Kafka Management
TranslatedAlibaba's MySQL binlog incremental subscription & consumption component
Empowering Data Intelligence with Distributed SQL for Sharding, Scalability, and Security Across All Databases.
Logstash - transport and process your logs, events, or other data
Apache Pulsar - distributed pub-sub messaging system
Apache Beam is a unified programming model for Batch and Streaming data processing.
Apache KIE (Knowledge Is Everything) is the home of Drools, OptaPlanner, jBPM, and Kogito.
A better compressed bitset in Java: used by Apache Spark, Netflix Atlas, Apache Pinot, Tablesaw, and many others
A cluster computing framework for processing large-scale geospatial data
Pentaho Data Integration ( ETL ) a.k.a Kettle
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.
Micro second messaging that stores everything to disk
Nessie: Transactional Catalog for Data Lakes with Git-like semantics
Database Subsetting and Relational Data Browsing Tool.
The swiss army knife of healthcare integration.
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.
Apache Ignite
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
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.
EventMesh is a new generation serverless event middleware for building distributed event-driven applications.
Maxwell's daemon, a mysql-to-json kafka producer
Confluent Schema Registry for Kafka
Apache InLong - a one-stop, full-scenario integration framework for massive data
Apache Linkis builds a computation middleware layer to facilitate connection, governance and orchestration between the upper applications and the underlying data engines.
Source-agnostic distributed change data capture system
LittleHorse Server: Business-as-Code Platform for Microservices, Workflows, and Agents
HiveMQ CE is a Java-based open source MQTT broker that fully supports MQTT 3.x and MQTT 5. It is the foundation of the HiveMQ Enterprise Connectivity and Messaging Platform
An extensible distributed system for reliable nearline data streaming at scale
A platform that makes it easy for developers to build realtime, cost-effective, operations-focused applications
Fast and reliable message broker built on top of Kafka.
JeroMQ is a pure Java implementation of the ZeroMQ messaging library, offering high-performance asynchronous messaging for distributed or concurrent applications.
An HTTP bridge for Apache Kafka®
Stream Processing and Complex Event Processing Engine
A distributed data integration framework that simplifies common aspects of big data integration such as data ingestion, replication, organization and lifecycle management for both streaming and batch data ecosystems.
Framework for building Event-Driven Microservices
Distributed Big Data Orchestration Service
An extensible Java framework for building event-driven applications that break up XML and non-XML data into chunks for data integration
An open source, a high-performance hybrid integration platform that allows developers quick integration with any application, data, or system.
:elephant: Elasticsearch real-time search and analytics natively integrated with Hadoop
Esper Complex Event Processing, Streaming SQL and Event Series Analysis
The MongoDB Spark Connector
The database purpose-built for stream processing applications.
Official Neo4j JDBC Driver
Apache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter
Secor is a service implementing Kafka log persistence
A high available,high performance distributed messaging system.
SQL-based streaming analytics platform at scale
Highly optimized, extremely modular and very flexible XMPP/Jabber server
Distributed Stream and Batch Processing
PipelinR is a lightweight command processing pipeline ❍ ⇢ ❍ ⇢ ❍ for your Java awesome app.
Emissary is simple, yet 🗲FAST🗲 messaging library for decoupling messages (requests and events) and message handlers 🚀
Ballerina MQTT Module.
A production-grade HBase ORM library that makes accessing HBase clean, fast and fun (Can also be used as Bigtable ORM)
Mirror of Apache Qpid Broker-J
Window-Based Hybrid CPU/GPU Stream Processing Engine