@Test
public void testGetClusterNodes() {

    final String[] brokerHostBits = sharedKafkaTestResource
        .getKafkaConnectString()
        .replaceAll("PLAINTEXT://", "")
        .split(":");
    final String brokerHost = brokerHostBits[0];
    final int brokerPort = Integer.valueOf(brokerHostBits[1]);
    final NodeList nodeList = kafkaOperations.getClusterNodes();
    logger.info("{}", nodeList);
    assertEquals("Should have single node", 1, nodeList.getNodes().size());
    final NodeDetails node = nodeList.getNodes().get(0);
    validateNode(node, 1, brokerHost, brokerPort);
}