145146147148149150151152153154155
kafkaConfig, kafkaLog, zkHostNames, zkPort); operation.execute(); } private Map<String, Integer> getBrokerIds(List<String> hostNames, File brokerIdFile) throws Exception { Map<String, Integer> brokerIds = new HashMap<String, Integer>();