3 个仓库
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
用 AI 发现最棒的仓库。我们将通过 AI 为您搜索最匹配的仓库。
- edenhill/kafkacat
edenhill/kafkacat
5,761在 GitHub 上查看Kafkacat 是一套用于与 Apache Kafka 集群交互的命令行实用程序。它提供了一个非 JVM 二进制文件，用于生产和消费消息、检查集群元数据以及通过终端调试 Kafka 协议。 该工具的功能包括作为生产者和消费者，能够从文件或标准输入推送数据，并从特定主题和分区读取消息。它包括一个元数据检查器，以纯文本或 JSON 格式检索集群状态和分区配置，以及一个用于检查消息偏移量、时间戳和二进制负载的协议调试器。 该项目涵盖使用模式或原始解码器进行数据反序列化，以及基于偏移量的查询以从精确时间戳检索数据。它还提供模拟实用程序来运行短暂的内存中 Broker，用于集成测试和性能基准测试。
Implements internal memory buffering to decouple network I/O from the production and consumption of Kafka messages.
C - coder/websocket
coder/websocket
5,299在 GitHub 上查看This 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,609在 GitHub 上查看This 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
