Awesome GitHub RepositoriesDistributed Messaging Inspections

kcat este un client de linie de comandă pentru Apache Kafka utilizat pentru a produce, consuma și depana mesaje folosind protocolul nativ. Oferă o suită de instrumente pentru interacțiunea cu clusterele Kafka, inclusiv un depanator de protocol pentru inspectarea metadatelor clusterului și un manager de tranzacții pentru gestionarea batch-urilor atomice de mesaje. Proiectul dispune de un decodor de schemă Avro specializat care convertește mesajele codificate binar în JSON lizibil pentru oameni prin integrarea cu registre de scheme la distanță sau fișiere locale. În plus, include un simulator în memorie care permite testarea logicii de producător și consumator prin simularea comportamentului brokerului efemer fără a necesita infrastructură externă. Setul de instrumente acoperă o gamă largă de operațiuni de mesagerie, inclusiv suport pentru grupuri de consumatori echilibrate, căutarea offset-ului bazată pe timestamp și streaming de date tranzacționale din input standard. De asemenea, oferă utilitare pentru configurarea securității conexiunii și inspectarea metadatelor clusterului.

Iggy este o platformă distribuită de streaming de mesaje și un broker de mesaje multi-protocol care funcționează ca un magazin de log-uri distribuite persistente. Oferă infrastructură pentru publicarea și consumarea mesajelor binare folosind un log de tip append-only, asigurând disponibilitate ridicată și consistența datelor între noduri prin Viewstamped Replication. Platforma se distinge prin infrastructura sa specializată de streaming pentru LLM-uri, care utilizează un protocol de server pentru a conecta modelele de limbaj mari la datele de streaming și la controalele sistemului. Aceasta include protocoale standardizate pentru gestionarea contextului și bridging-ul datelor prin HTTP sau input-output standard. Sistemul acoperă un set larg de capabilități, inclusiv orchestrarea pipeline-urilor de date cu plugin-uri modulare de sursă și destinație, coordonarea grupurilor de consumatori pentru scalare orizontală și suport pentru transport multi-protocol prin TCP, QUIC, HTTP și WebSocket. De asemenea, încorporează primitive de securitate precum criptarea AES-256-GCM pentru datele stocate și în tranzit, și oferă observabilitate prin metrici Prometheus, tracing OpenTelemetry și un dashboard web operațional. Serverul poate fi implementat folosind imagini de container și orchestrat prin Kubernetes.

LiveEventBus este o bibliotecă de comunicare AndroidX care oferă un message bus pentru transferul decuplat de date între componentele aplicației. Utilizează LiveData pentru a implementa un message bus conștient de ciclul de viață, asigurându-se că abonamentele la evenimente sunt gestionate automat pe baza stării componentelor Android pentru a preveni scurgerile de memorie. Biblioteca include o punte de comunicare inter-proces care permite transferul de date serializate și evenimente între diferite procese sau aplicații separate. De asemenea, dispune de un dispatcher de evenimente sticky care reține și livrează imediat cel mai recent mesaj noilor abonați la înregistrare. Framework-ul acoperă rutarea mesajelor interne și inter-proces, programarea mesajelor întârziate și serializarea datelor. Oferă, de asemenea, utilitare pentru inspecția stării message bus-ului, pentru a monitoriza observatorii activi și receiverele înregistrate.