An extensible distributed system for reliable nearline data streaming at scale
- distributed-systems
- data-streaming
- scalability
- kafka-mirror-maker
47,133 repositories indexed
49–66 of 66 · Most stars
An extensible distributed system for reliable nearline data streaming at scale
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.
Universal, flexible, high-performance distributed ID generator. | 通用、灵活、高性能的分布式 ID 生成器
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
A distributed system designed to ingest and process time series data
Distributed database specialized in exporting key/value data from Hadoop
Provides tracing abstractions over tracers and tracing system reporters.
[UNMAINTAINED] Meteor's Distributed Data Protocol (DDP) for clients on Android
Distributed Temporal Graph Analytics with Apache Flink
Apache Storm + OpenCV = large scale distributed image and video analysis.
The legacy distributed object storage server developed by PitchPoint Solutions can store billions of large and small files using minimal resources. Object data is stored in replicated volumes implemented like Facebooks Haystack Object Store. Object metadata which essentially maps an object name to a volume position is stored in an elasticsearch index. (Development by PitchPoint Solutions has been discontinued)
A blueprint adapting VertX to distributed game server
Consul - based cluster manager that can be plugged into Vert.x ecosystem.
Distributed, Scalable, Fault-Tolerant, Minimalistic Workflow Engine - No DAGs, No YAML, No Cumbersome Diagrams, Just Code
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.
Demonstration of the inspectIT APM tool with distributed version of Spring Petclinic built with Spring Cloud
Estimating the number of clusters in a data set via the gap statistic. Implemented in H2O-3
Implementation of Partitioning Around Medoids (PAM) in H2O-3