KafkaInfos.java 文件源码

@Override
public void close() {
  for (SimpleConsumer consumer : consumerMap.values()) {
    if (consumer != null) {
      consumer.close();
    }
  }
  if (zkClient != null) {
    zkClient.close();
  }
}