KafkaInfos.java 文件源码

private List<BrokerInfo> getBrokerInfos() {
  List<BrokerInfo> infos = Lists.newArrayListWithExpectedSize(consumerMap.size());
  for (Map.Entry<Integer, SimpleConsumer> entry : consumerMap.entrySet()) {
    BrokerInfo info = new BrokerInfo();
    info.id = entry.getKey();
    info.host = entry.getValue().host();
    info.port = entry.getValue().port();
    infos.add(info);
  }
  return infos;
}