Skip to content

Commit f510fbd

Browse files
committed
Add prefix to serde names
1 parent 435c4fd commit f510fbd

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010

1111
@Slf4j
1212
public class CheckpointSerde extends MirrorMakerSerde implements BuiltInSerde {
13-
public static final String NAME = "Checkpoint";
13+
public static final String NAME = "mm2-Checkpoint";
1414
public static final Pattern TOPIC_NAME_PATTERN = Pattern.compile(".*\\.checkpoints\\.internal");
1515

1616
private static final String TOPIC_KEY = "topic";

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010

1111
@Slf4j
1212
public class HeartbeatSerde extends MirrorMakerSerde implements BuiltInSerde {
13-
public static final String NAME = "Heartbeat";
13+
public static final String NAME = "mm2-Heartbeat";
1414
public static final Pattern TOPIC_NAME_PATTERN = Pattern.compile("heartbeats");
1515

1616
private static final String SOURCE_CLUSTER_ALIAS_KEY = "sourceClusterAlias";

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010

1111
@Slf4j
1212
public class OffsetSyncSerde extends MirrorMakerSerde implements BuiltInSerde {
13-
public static final String NAME = "OffsetSync";
13+
public static final String NAME = "mm2-OffsetSync";
1414
public static final Pattern TOPIC_NAME_PATTERN = Pattern.compile("mm2-offset-syncs\\..*\\.internal");
1515

1616
private static final Schema VALUE_SCHEMA;

0 commit comments

Comments
 (0)