[rocketmq-clients] branch master updated: fix: setGroup() invoked twice when wrapAckMessageRequest() (#522)

[aa...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 447c3bee fix: setGroup() invoked twice when wrapAckMessageRequest() (#522)
447c3bee is described below

commit 447c3bee83e9117eae53656bffe9e6ea54bcebf4
Author: Quan <zs...@foxmail.com>
AuthorDate: Thu May 25 14:13:56 2023 +0800

    fix: setGroup() invoked twice when wrapAckMessageRequest() (#522)
    
    Co-authored-by: Quan <vi...@alibaba-inc.com>
---
 .../org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
index 3efcb540..5175b4dd 100644
--- 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 @@ abstract class ConsumerImpl extends ClientImpl {
             .setReceiptHandle(messageView.getReceiptHandle())
             .build();
         return AckMessageRequest.newBuilder().setGroup(getProtobufGroup()).setTopic(topicResource)
-            .setGroup(getProtobufGroup()).addEntries(entry).build();
+            .addEntries(entry).build();
     }
 
     private ChangeInvisibleDurationRequest wrapChangeInvisibleDuration(MessageViewImpl messageView,