@Test
public void noRack() throws Exception {

  BrokerNode brokerNode = new BrokerNode(1, "none", "host");
  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();
  BrokerNode result = underTest.apply(x -> true);
  assertThat(result, is(brokerNode));
}