2 repository-uri
Message queuing systems optimized for cloud environments using object storage for persistence.
Distinct from Message Queues: Distinct from general message queues by the specific requirement of being cloud-native and S3-backed.
Explore 2 awesome GitHub repositories matching data & databases · Cloud Native Message Queues. Refine with filters or upvote what's useful.
AutoMQ is a cloud-native streaming platform and Apache Kafka distribution that implements a decoupled compute and storage architecture. It functions as an S3-backed message queue, using object storage as the primary log repository to eliminate dependencies on local disks. The platform utilizes a stateless broker architecture to enable dynamic compute scaling and automated partition balancing. This design allows the system to adjust the number of brokers in seconds and distribute network traffic without requiring manual data migration or partition reassignment. The system provides multi-avail
Provides a Kafka-compatible streaming platform that uses object storage to remove local disk dependencies.
Jocko este o platformă de event streaming cloud-native și un jurnal de commit-uri distribuit, implementat în Go. Funcționează ca un broker de mesaje distribuit care asigură durabilitatea datelor și disponibilitatea ridicată prin replicarea secvențelor de înregistrări într-un cluster. Sistemul este conceput ca un streamer de evenimente fără Zookeeper, utilizând coordonarea prin consens integrată pentru a gestiona starea clusterului și alegerea liderului fără a necesita servicii de coordonare externe. Implementează protocolul Kafka, permițându-i să comunice cu clienții și instrumentele din ecosistemul existent. Platforma oferă capabilități pentru gestionarea jurnalelor distribuite, inclusiv utilizarea unui jurnal de commit-uri de tip append-only pentru persistența datelor. Include, de asemenea, mecanisme automate de retenție a datelor care elimină înregistrările vechi în funcție de limitele de timp sau pragurile de spațiu pe disc. Proiectul este distribuit ca un runtime de tip single-binary.
Provides a lightweight messaging cluster optimized for cloud-native deployment as a single binary.