RockteMQ-AI commented on issue #1325: URL: https://github.com/apache/rocketmq-clients/issues/1325#issuecomment-5240680662
**Issue Evaluation** Category: `enhancement` | Status: **Evaluated** **Feasibility:** feasible **Scope:** Java gRPC client (PushConsumer), Proxy ack handling **Compatibility:** backward-compatible (wire protocol already supports batched entries) The proposal is well-scoped. The gRPC `AckMessageRequest.entries` repeated field already supports batching on the wire, so the change is primarily on the client-side accumulation logic and the Proxy-side dispatch. Key considerations: - Accumulation window should be configurable (count-based + time-based flush) - Partial-ack semantics: if one entry in a batch fails, the whole batch should be retried or individual failures should be tracked - Backpressure: the accumulator needs bounds to avoid unbounded memory growth under slow Proxy This is a solid optimization for high-throughput scenarios. --- *Automated evaluation by RockteMQ-AI* -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
