From b4080a3d2e53e15ea46b9969eee3e7bdbd84a087 Mon Sep 17 00:00:00 2001
From: qianye <wuxingcan.wxc@alibaba-inc.com>
Date: Thu, 3 Jul 2025 14:25:04 +0800
Subject: [PATCH] fix

---
 .../rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
index c470eda55ca..9ee3f4fddd4 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
@@ -358,7 +358,14 @@ public void notifyClientTermination(NotifyClientTerminationRequest request,
     @Override
     public void changeInvisibleDuration(ChangeInvisibleDurationRequest request,
         StreamObserver<ChangeInvisibleDurationResponse> responseObserver) {
-        Function<Status, ChangeInvisibleDurationResponse> statusResponseCreator = status -> ChangeInvisibleDurationResponse.newBuilder().setStatus(status).build();
+        Function<Status, ChangeInvisibleDurationResponse> statusResponseCreator = status -> {
+            ChangeInvisibleDurationResponse.Builder builder =
+                ChangeInvisibleDurationResponse.newBuilder().setStatus(status);
+            if (Code.TOO_MANY_REQUESTS.equals(status.getCode())) {
+                builder.setReceiptHandle(request.getReceiptHandle());
+            }
+            return builder.build();
+        };
         ProxyContext context = createContext();
         try {
             this.addExecutor(this.consumerThreadPoolExecutor,