@Test
public void test_KafkaZkConnection_createPath() throws Exception {

    List<ComponentProcess> brokerProcesses = getBrokerComponentProcesses();
    Deencapsulation.setField(kafkaMetadataService, "kafkaBrokerProcesses", brokerProcesses);
    for (String zkStr : zkStrs) {
        for (String chRoot : chRoots) {
            final String zkStrRaw = zkStr + chRoot;
            LOG.debug("zookeeper.connect=" + zkStrRaw);
            KafkaMetadataService.KafkaZkConnection kafkaZkConnection = KafkaMetadataService.KafkaZkConnection.newInstance(zkStrRaw);
            final String zkPath = kafkaZkConnection.buildZkRootPath(ZK_RELATIVE_PATH_KAFKA_BROKERS_IDS);
            Assert.assertEquals(chRoot.isEmpty() ? expectedBrokerIdPath.get(0) : expectedBrokerIdPath.get(1), zkPath);
        }
    }
}