You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2023/05/17 09:26:11 UTC
[rocketmq] branch develop updated: Remove redundant variables (#6740)
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 <63...@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