TestSourceKafkaClusterValidationManager.java 文件源码

@AfterTest
public void shutdown() {
  LOGGER.info("Trying to shutdown");
  helixMirrorMakerManager.stop();
  kafkaBrokerTopicObserver.stop();
  KafkaStarterUtils.stopServer(kafkaStarter);
  ZkStarter.stopLocalZkServer();
}