fix: setGroup() invoked twice when wrapAckMessageRequest() (#522)

f1amingo · Quan · web-flow · commit 447c3bee83e9 · 2023-05-25T14:13:56.000+08:00
Co-authored-by: Quan &lt;vincent.zsj@alibaba-inc.com&gt;
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java
@@ -128,7 +128,7 @@ private AckMessageRequest wrapAckMessageRequest(MessageViewImpl messageView) {
             .setReceiptHandle(messageView.getReceiptHandle())
             .build();
         return AckMessageRequest.newBuilder().setGroup(getProtobufGroup()).setTopic(topicResource)
-            .setGroup(getProtobufGroup()).addEntries(entry).build();
+            .addEntries(entry).build();
     }
 
     private ChangeInvisibleDurationRequest wrapChangeInvisibleDuration(MessageViewImpl messageView,

Original file line number	Diff line number	Diff line change
`@@ -128,7 +128,7 @@ private AckMessageRequest wrapAckMessageRequest(MessageViewImpl messageView) {`
`128`	`128`	`.setReceiptHandle(messageView.getReceiptHandle())`
`129`	`129`	`.build();`
`130`	`130`	`return AckMessageRequest.newBuilder().setGroup(getProtobufGroup()).setTopic(topicResource)`
`131`		`- .setGroup(getProtobufGroup()).addEntries(entry).build();`
	`131`	`+ .addEntries(entry).build();`
`132`	`132`	`}`
`133`	`133`
`134`	`134`	`private ChangeInvisibleDurationRequest wrapChangeInvisibleDuration(MessageViewImpl messageView,`