From 861ecf2bcd1c372b0b1c9d3adbf243218bcb1094 Mon Sep 17 00:00:00 2001 From: "dongyuan.pdy" Date: Thu, 4 Aug 2022 10:21:34 +0800 Subject: [PATCH] bug fix: change groupid --- .../java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java | 2 +- .../java/org/apache/rocketmq/mqtt/meta/raft/CounterClient.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java b/meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java index 7c9835545..8bf5e0c8c 100644 --- a/meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java +++ b/meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java @@ -78,7 +78,7 @@ public class MqttRaftServer { private static final Logger LOGGER = LoggerFactory.getLogger(MqttRaftServer.class); - private static final String GROUP_SEQ_NUM_SPLIT = "%"; + private static final String GROUP_SEQ_NUM_SPLIT = "-"; @Resource private MetaConf metaConf; diff --git a/meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/CounterClient.java b/meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/CounterClient.java index 566a6a5f8..330fa7565 100644 --- a/meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/CounterClient.java +++ b/meta/src/test/java/org/apache/rocketmq/mqtt/meta/raft/CounterClient.java @@ -35,7 +35,7 @@ import java.util.concurrent.Executor; public class CounterClient { - private static final String GROUP_SEQ_NUM_SPLIT = "%"; + private static final String GROUP_SEQ_NUM_SPLIT = "-"; public static void main(final String[] args) throws Exception {