@BeforeEach
    public void startClusters() throws Exception {
        replicateBackupToPrimary = false;
        super.startClusters(new HashMap<String, String>() {{
                put("replication.policy.class", IdentityReplicationPolicy.class.getName());
                put("topics", "test-topic-.*");
            }});
    }
Tests MM2 replication and failover logic for {@link IdentityReplicationPolicy}.

<p>MM2 is configured with active/passive replication between two Kafka clusters with {@link IdentityReplicationPolicy}.
Tests validate that records sent to the primary cluster arrive at the backup cluster. Then, a consumer group is
migrated from the primary cluster to the backup cluster. Tests validate that consumer offsets
are translated and replicated from the primary cluster to the backup cluster during this failover.
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/IdentityReplicationIntegrationTest.java