@Test(expected = RuntimeException.class)
public void notFound() throws Exception {

  Node node = new Node(1, "host", 9092, null);
  KafkaFuture<Collection<Node>> kafkaFuture = completedFuture(singleton(node));
  doReturn(describeClusterResult).when(adminClient).describeCluster();
  doReturn(kafkaFuture).when(describeClusterResult).nodes();
  underTest.apply(x -> false);
}