[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
apache · Sep 6, 2024 · 5496807 · 5496807
1 parent 97b318f
commit 5496807
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 0 deletions.
diff --git a/...er/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java b/...er/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java
@@ -43,4 +43,13 @@ public void updateSubscriptionGroupConfig(final SubscriptionGroupConfig config)
         }
         super.updateSubscriptionGroupConfig(config);
     }
+
+    @Override
+    public boolean containsSubscriptionGroup(String group) {
+        if (MixAll.isLmq(group)) {
+            return true;
+        } else {
+            return super.containsSubscriptionGroup(group);
+        }
+    }
 }
diff --git a/...main/java/org/apache/rocketmq/broker/subscription/RocksDBLmqSubscriptionGroupManager.java b/...main/java/org/apache/rocketmq/broker/subscription/RocksDBLmqSubscriptionGroupManager.java
@@ -43,4 +43,13 @@ public void updateSubscriptionGroupConfig(final SubscriptionGroupConfig config)
         }
         super.updateSubscriptionGroupConfig(config);
     }
+
+    @Override
+    public boolean containsSubscriptionGroup(String group) {
+        if (MixAll.isLmq(group)) {
+            return true;
+        } else {
+            return super.containsSubscriptionGroup(group);
+        }
+    }
 }