Page History

public class MirrorCheckpointTask extends SourceTask {
    ..
    boolean shouldCheckpointTopic(String topic) {
            return topicFilter.shouldReplicateTopic(topic) && !internalTopicPolicy.isInternalTopic(topic);
        }
}

public class MirrorSourceConnector extends SourceConnector {
    ...
    boolean shouldReplicateTopic(String topic) {
            return (topicFilter.shouldReplicateTopic(topic) || isHeartbeatTopic(topic))
                && !internalTopicPolicy.isInternalTopicisMM2InternalTopic(topic) && !isCycle(topic);
        }
}