3 repositorios
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
Encuentra los mejores repositorios con IA.Buscaremos los repositorios que mejor coincidan usando IA.
- edenhill/kafkacat
edenhill/kafkacat
5,761Ver en GitHubKafkacat es un conjunto de utilidades de línea de comandos para interactuar con clusters de Apache Kafka. Proporciona un binario no JVM para producir y consumir mensajes, inspeccionar metadatos del cluster y depurar el protocolo Kafka a través de la terminal. La herramienta funciona como un productor y consumidor capaz de enviar datos desde archivos o entrada estándar y leer mensajes de temas y particiones específicos. Incluye un inspector de metadatos para recuperar el estado del cluster y las configuraciones de partición en texto plano o JSON, así como un depurador de protocolos para inspeccionar offsets de mensajes, marcas de tiempo y cargas útiles binarias. El proyecto cubre la deserialización de datos utilizando esquemas o decodificadores primitivos y consultas basadas en offset para recuperar datos de marcas de tiempo precisas. También proporciona utilidades de simulación para ejecutar brokers efímeros en memoria para pruebas de integración y benchmarking de rendimiento.
Implements internal memory buffering to decouple network I/O from the production and consumption of Kafka messages.
C - coder/websocket
coder/websocket
5,299Ver en 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,609Ver en 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
