BE: Serde: Impl MM2 serdes (#1381)

Author: Haarolean

api/src/main/java/io/kafbat/ui/serdes/SerdesInitializer.java

@@ -173,9 +173,9 @@ private Map<String, SerdeInstance> mirrorMakerSerdes() {
         HeartbeatSerde.NAME,
         mirrorSerde(HeartbeatSerde.NAME, HeartbeatSerde.TOPIC_NAME_PATTERN, new HeartbeatSerde()),
         OffsetSyncSerde.NAME,
-        mirrorSerde(HeartbeatSerde.NAME, OffsetSyncSerde.TOPIC_NAME_PATTERN, new OffsetSyncSerde()),
+        mirrorSerde(OffsetSyncSerde.NAME, OffsetSyncSerde.TOPIC_NAME_PATTERN, new OffsetSyncSerde()),
         CheckpointSerde.NAME,
-        mirrorSerde(HeartbeatSerde.NAME, CheckpointSerde.TOPIC_NAME_PATTERN, new CheckpointSerde())
+        mirrorSerde(CheckpointSerde.NAME, CheckpointSerde.TOPIC_NAME_PATTERN, new CheckpointSerde())
     );
   }
 

api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/CheckpointSerde.java

@@ -10,7 +10,7 @@
 
 @Slf4j
 public class CheckpointSerde extends MirrorMakerSerde implements BuiltInSerde {
-  public static final String NAME = "Checkpoint";
+  public static final String NAME = "mm2-Checkpoint";
   public static final Pattern TOPIC_NAME_PATTERN = Pattern.compile(".*\\.checkpoints\\.internal");
 
   private static final String TOPIC_KEY = "topic";

api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/HeartbeatSerde.java

@@ -10,7 +10,7 @@
 
 @Slf4j
 public class HeartbeatSerde extends MirrorMakerSerde implements BuiltInSerde {
-  public static final String NAME = "Heartbeat";
+  public static final String NAME = "mm2-Heartbeat";
   public static final Pattern TOPIC_NAME_PATTERN = Pattern.compile("heartbeats");
 
   private static final String SOURCE_CLUSTER_ALIAS_KEY = "sourceClusterAlias";

api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/OffsetSyncSerde.java

@@ -10,7 +10,7 @@
 
 @Slf4j
 public class OffsetSyncSerde extends MirrorMakerSerde implements BuiltInSerde {
-  public static final String NAME = "OffsetSync";
+  public static final String NAME = "mm2-OffsetSync";
   public static final Pattern TOPIC_NAME_PATTERN = Pattern.compile("mm2-offset-syncs\\..*\\.internal");
 
   private static final Schema VALUE_SCHEMA;