@Test
public void testRemoveMember() throws InterruptedException {

    ClusterMembershipRevision<ClusterMember> revision = newMemberRevision();
    String memberId = revision.getCurrent().getMemberId();
    ClusterMembershipRevision<ClusterMember> result = executor.createLocal(revision).block();
    executor.removeMember(memberId).block();
    try {
        executor.getMemberById(memberId).block();
        fail("Found removed member");
    } catch (Exception e) {
        assertThat(KubeUtils.is4xx(e)).isTrue();
    }
    expectClusterMembershipChangeEvent(result, ClusterMembershipChangeEvent.ChangeType.Added);
    assertThat(findNextMemberEvent(memberId)).isNotNull();
}