[rocketmq] branch develop updated: Remove redundant variables (#6740)

[yukon]

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

yukon pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 70480a1fa Remove redundant variables (#6740)
70480a1fa is described below

commit 70480a1fa9aac397fa8c5dbcb352284ad118a891
Author: haiyanghan <63851981+haiyang...@users.noreply.github.com>
AuthorDate: Wed May 17 17:25:59 2023 +0800

    Remove redundant variables (#6740)
---
 .../apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
 
b/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
index 1b9cd63db..900e82211 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
@@ -90,8 +90,7 @@ public class RemoteBrokerOffsetStore implements OffsetStore {
                 case READ_FROM_STORE: {
                     try {
                         long brokerOffset = 
this.fetchConsumeOffsetFromBroker(mq);
-                        AtomicLong offset = new AtomicLong(brokerOffset);
-                        this.updateOffset(mq, offset.get(), false);
+                        this.updateOffset(mq, brokerOffset, false);
                         return brokerOffset;
                     }
                     // No offset in broker