THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
@InterfaceStability.Evolving public interface ReplicationPolicy extends Configurable { .... /** Returns heartbeats topic name.*/ default String heartbeatsTopic() { return "heartbeats";} /** Returns the offset-syncs topic for given cluster alias. */ default String offsetSyncTopic(String targetAlias) { return " mm2-offset-syncs." + targetCluster + ".internal";} /** Returns the name checkpoint topic for given cluster alias. */ default String checkpointTopic(String clusterAlias) { return clusterAlias + ".checkpoint.internal"; } /** check if topic is a heartbeat topic, e.g heartbeats, us-west.heartbeats. */ default boolean isHeartbeatTopic(String topic) { return heartbeatsTopic().equals(originalTopic(topic)); } /** check if topic is a checkpoint topic. */ default boolean isCheckpointTopic(String topic) {return topic.endsWith(".checkpoint.internal")} /** Check topic is one of MM2 internal topic, this is used to make sure the topic doesn't need to be replicated.*/ default boolean isMM2InternalTopic(String topic) {return topic.endsWith("-.internal");} /** Internal topics are never replicated. */ default boolean isInternalTopic(String topic) { boolean isKafkaInternalTopic = topic.startsWith("__") || topic.startsWith(".") || topic.endsWith("-internal"); return isMM2InternalTopic(topic) || isKafkaInternalTopic; } } |
...