Remove redundant variables (#6740)

apache · May 17, 2023 · 70480a1 · 70480a1
1 parent 92ea901
commit 70480a1
Showing 1 changed file with 1 addition and 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
@@ -90,8 +90,7 @@ public long readOffset(final MessageQueue mq, final ReadOffsetType type) {
                 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