You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ca...@apache.org on 2024/09/06 08:15:13 UTC
(rocketmq) branch develop updated: [ISSUE #8647] Fix the issue where lmq cannot update consumer offset (#8648)
This is an automated email from the ASF dual-hosted git repository.
caigy 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 5496807572 [ISSUE #8647] Fix the issue where lmq cannot update consumer offset (#8648)
5496807572 is described below
commit 5496807572f3803d2c6fc3d0f1671dc5f149a2f9
Author: rongtong <ji...@mails.ucas.ac.cn>
AuthorDate: Fri Sep 6 16:15:08 2024 +0800
[ISSUE #8647] Fix the issue where lmq cannot update consumer offset (#8648)
* Fix the issue where lmq cannot update consumer offset
* Fix the issue where lmq cannot update consumer offset
---
.../broker/subscription/LmqSubscriptionGroupManager.java | 9 +++++++++
.../broker/subscription/RocksDBLmqSubscriptionGroupManager.java | 9 +++++++++
2 files changed, 18 insertions(+)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java b/broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java
index 018083811e..69e59fd8e7 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java
@@ -43,4 +43,13 @@ public class LmqSubscriptionGroupManager extends SubscriptionGroupManager {
}
super.updateSubscriptionGroupConfig(config);
}
+
+ @Override
+ public boolean containsSubscriptionGroup(String group) {
+ if (MixAll.isLmq(group)) {
+ return true;
+ } else {
+ return super.containsSubscriptionGroup(group);
+ }
+ }
}
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/subscription/RocksDBLmqSubscriptionGroupManager.java b/broker/src/main/java/org/apache/rocketmq/broker/subscription/RocksDBLmqSubscriptionGroupManager.java
index 8c05d0bd98..e4de25756b 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/subscription/RocksDBLmqSubscriptionGroupManager.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/subscription/RocksDBLmqSubscriptionGroupManager.java
@@ -43,4 +43,13 @@ public class RocksDBLmqSubscriptionGroupManager extends RocksDBSubscriptionGroup
}
super.updateSubscriptionGroupConfig(config);
}
+
+ @Override
+ public boolean containsSubscriptionGroup(String group) {
+ if (MixAll.isLmq(group)) {
+ return true;
+ } else {
+ return super.containsSubscriptionGroup(group);
+ }
+ }
}