Skip to content

Commit e92e996

Browse files
committed
fix: stale wildcardGroupMap entries caused by incorrect parsing during LiteTopic wildcard unregistration
1 parent 9879968 commit e92e996

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

broker/src/main/java/org/apache/rocketmq/broker/lite/LiteSubscriptionRegistryImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -400,7 +400,7 @@ private void markWildcardGroup(String topic, String group) {
400400

401401
private void unmarkWildcardGroupIfNecessary(String lmqName) {
402402
if (!LiteUtil.isLiteTopicQueue(lmqName)) { // must be topic@group
403-
String[] topicAtGroup = StringUtils.split(lmqName);
403+
String[] topicAtGroup = StringUtils.split(lmqName, "@");
404404
if (null == topicAtGroup || topicAtGroup.length != 2) {
405405
return;
406406
}

0 commit comments

Comments
 (0)