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

jinrongtong 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 1cdcce198 [ISSUE #5560] Method parameters are passed in the wrong 
order (#5561)
1cdcce198 is described below

commit 1cdcce1988e927e4f705f67c8c9683888c0606cf
Author: zhangjidi2016 <[email protected]>
AuthorDate: Tue Nov 22 20:54:31 2022 +0800

    [ISSUE #5560] Method parameters are passed in the wrong order (#5561)
    
    Co-authored-by: zhangjidi <[email protected]>
---
 .../java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index 4701a9a69..b4ec95647 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -1978,7 +1978,7 @@ public class AdminBrokerProcessor implements 
NettyRequestProcessor {
             .queryMinOffsetInAllGroup(requestHeader.getTopic(), 
requestHeader.getFilterGroups());
 
         Map<Integer, Long> compareOffset =
-            
this.brokerController.getConsumerOffsetManager().queryOffset(requestHeader.getTopic(),
 requestHeader.getCompareGroup());
+            
this.brokerController.getConsumerOffsetManager().queryOffset(requestHeader.getCompareGroup(),
 requestHeader.getTopic());
 
         if (compareOffset != null && !compareOffset.isEmpty()) {
             for (Map.Entry<Integer, Long> entry : compareOffset.entrySet()) {

Reply via email to