ControllerStarterTest.java 文件源码

@AfterTest
public void shutdown() {
  LOGGER.info("Trying to shutdown");
  for (FakeInstance fakeInstance : FAKE_INSTANCES) {
    try {
      LOGGER.info("Trying to shutdown: " + fakeInstance);
      fakeInstance.stop();
    } catch (Exception e) {
    }
  }
  LOGGER.info("Trying to stop controller");
  CONTROLLER_STARTER.stop();
  LOGGER.info("Trying to stop zk");

  kafkaBrokerTopicObserver.stop();
  KafkaStarterUtils.stopServer(kafkaStarter);

  ZK_CLIENT.deleteRecursive("/" + HELIX_CLUSTER_NAME);
  ZK_CLIENT.close();
  ZkStarter.stopLocalZkServer();
}