[rocketmq-mqtt] branch develop updated: bug fix: change groupid

[pingww]

This is an automated email from the ASF dual-hosted git repository.

pingww pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git


The following commit(s) were added to refs/heads/develop by this push:
     new 861ecf2  bug fix: change groupid
     new c8f6b55  Merge pull request #134 from DongyuanPan/develop_groupID
861ecf2 is described below

commit 861ecf2bcd1c372b0b1c9d3adbf243218bcb1094
Author: dongyuan.pdy <dongyuanp...@gmail.com>
AuthorDate: Thu Aug 4 10:21:34 2022 +0800

    bug fix: change groupid
---
 .../main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java    | 2 +-
 .../src/test/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 7c98355..8bf5e0c 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 @@ import java.util.concurrent.LinkedBlockingQueue;
 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 566a6a5..330fa75 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.CountDownLatch;
 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 {