3 repository-uri
Awesome GitHub RepositoriesMessage Streaming Buffers
Internal memory buffers used to decouple network I/O from message consumption and production in streaming systems.
Distinct from Stream Buffering: Distinct from Stream Buffering: focuses on the decoupling of network I/O for message brokers rather than raw media piping between processes.
Explore 3 awesome GitHub repositories matching software engineering & architecture · Message Streaming Buffers. Refine with filters or upvote what's useful.
Awesome Message Streaming Buffers GitHub Repositories
Găsește cele mai bune repo-uri cu AI.Vom căuta cele mai potrivite repository-uri folosind AI.
- edenhill/kafkacat
edenhill/kafkacat
5,761Vezi pe GitHubKafkacat este o suită de utilitare de linie de comandă pentru interacțiunea cu clusterele Apache Kafka. Oferă un binar non-JVM pentru producerea și consumarea mesajelor, inspectarea metadatelor clusterului și depanarea protocolului Kafka prin terminal. Instrumentul funcționează ca un producător și consumator capabil să trimită date din fișiere sau input standard și să citească mesaje din topicuri și partiții specifice. Include un inspector de metadate pentru a prelua starea clusterului și configurațiile partițiilor în text simplu sau JSON, precum și un depanator de protocol pentru inspectarea offset-urilor mesajelor, timestamp-urilor și payload-urilor binare. Proiectul acoperă deserializarea datelor folosind scheme sau decodoare primitive și interogarea bazată pe offset pentru a prelua date de la timestamp-uri precise. De asemenea, oferă utilitare de simulare pentru a rula brokeri efemeri în memorie pentru testarea integrării și benchmarking-ul performanței.
Implements internal memory buffering to decouple network I/O from the production and consumption of Kafka messages.
C - coder/websocket
coder/websocket
5,299Vezi pe GitHubThis is a minimal WebSocket library for Go designed for bidirectional real-time communication. It serves as a network protocol implementation for managing handshakes, frame masking, and control signals to enable the exchange of text and binary messages over persistent connections. The library distinguishes itself by providing a connectivity layer that wraps browser WebSocket APIs for applications compiled to WebAssembly. It also functions as data compression middleware, utilizing deflate compression to reduce bandwidth usage for transmitted messages. The project covers a broad range of netwo
Implements memory buffers to decouple network I/O from message processing for large payloads.
Gogohttp2idiomatic - websockets-rs/rust-websocket
websockets-rs/rust-websocket
1,609Vezi pe GitHubThis project is a library for establishing bidirectional, real-time communication channels between clients and servers using the WebSocket protocol. It provides a foundational toolkit for managing persistent network connections and processing data frames in accordance with the RFC 6455 standard. The library distinguishes itself through its focus on low-level control and network efficiency. It utilizes an asynchronous, event-driven architecture to manage multiple concurrent connections without requiring dedicated threads for each session. Developers can fine-tune data transmission through manu
Uses internal memory buffers to decouple network I/O from message processing for improved throughput.
Rust
