@Test
public void testStaleMemberRemoval() throws InterruptedException {

    ClusterMembershipRevision<ClusterMember> stale = clusterMemberRegistrationRevision(activeClusterMember("staleSibling")).toBuilder()
            .withTimestamp(1)
            .build();
    kubeExecutors.addOrUpdateSibling(stale);
    // Now add normal
    doAddSibling("sibling1");
    assertThat(connector.getClusterMemberSiblings()).containsKey("sibling1");
    await().until(() -> kubeExecutors.getMemberById("staleSibling").map(r -> "staleSibling").onErrorReturn("null").block().equals("null"));
}