RockteMQ-AI commented on issue #11049: URL: https://github.com/apache/rocketmq/issues/11049#issuecomment-5553411500
**Issue Evaluation** Category: `bug` | Status: **Confirmed** The reported issue has been verified against the current codebase. **Root Cause:** The v2 gRPC proxy collapses N-message batch sends into a single `SendResult`, but `SendMessageActivity#convertToSendMessageResponse` builds only one response entry. SDKs validate receipt count and fail the send when `entries.size() != messages.size()`, causing retries that duplicate already-persisted messages. **Impact:** Proxy gRPC batch send path (local and cluster mode). All v2 SDKs (Java/Go/C++/C#/Rust) reject the malformed response and retry, duplicating messages. **Severity:** High — data duplication and send failures in production batch workloads. **Fix Status:** PR #11050 addresses this by expanding the batch result into per-message entries in `convertToSendMessageResponse`, matching the existing `ProduceAccumulator#splitSendResults` algorithm. --- *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]
