@Test
public void testRegistrationConnectionErrorInRegistrationRequest() throws InterruptedException {

    kubeExecutors.failOnMembershipUpdate(new RuntimeException("Simulated membership update error"), 1);
    try {
        connector.register(ClusterMemberGenerator::clusterMemberRegistrationRevision).block();
        fail("Failure expected");
    } catch (Exception ignore) {
    }
    doRegister();
}