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()) {