@SafeVarargs
    protected static void resetAllMirrorMakerConnectorOffsets(EmbeddedConnectCluster connectCluster, Class<? extends Connector>... connectorClasses) {
        for (Class<? extends Connector> connectorClass : connectorClasses) {
            String connectorName = connectorClass.getSimpleName();
            connectCluster.resetConnectorOffsets(connectorName);
            assertEquals(
                    Collections.emptyList(),
                    connectCluster.connectorOffsets(connectorName).offsets(),
                    "Offsets for connector should be completely empty after full reset"
            );
        }
    }
Tests MM2 replication and failover/failback logic.

MM2 is configured with active/active replication between two Kafka clusters. Tests validate that
records sent to either cluster arrive at the other cluster. Then, a consumer group is migrated from
one cluster to the other and back. Tests validate that consumer offsets are translated and replicated
between clusters during this failover and failback.
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationBaseTest.java