@Override
    public String upstreamTopic(String topic) {
        if (looksLikeHeartbeat(topic)) {
            return super.upstreamTopic(topic);
        } else {
            return topic;
        }
    }
Since any topic may be a remote topic, this just returns `topic`.
<p>
In the special case of heartbeats, we defer to {@link DefaultReplicationPolicy#upstreamTopic(String)}.
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/IdentityReplicationPolicy.java