@Test
public void testDiscoveryOfSiblingLeader() throws InterruptedException {

    ClusterMemberLeadership sibling = electSiblingAsLeader();
    ClusterMembershipRevision<ClusterMemberLeadership> leader = connector.findCurrentLeader().orElseThrow(() -> new IllegalStateException("Leader not found"));
    assertThat(leader.getCurrent()).isEqualTo(sibling);
}