@Override
  public void tearDown() {
    systemAdmin.stop();

   /*
    * Close joins on AdminClientRunnable thread and at times, it takes longer than the test timeouts, resulting
    * in test failures. Using a bounded close ensures tests passes successfully. Note, in the event of timeout,
    * close notifies AdminClientRunnable thread which in turn closes the underlying client quietly and
    * it shouldn't impact the tests nor have any side effects.
    */
    adminClient.close(ADMIN_OPERATION_WAIT_DURATION_MS, TimeUnit.MILLISECONDS);
    consumer.unsubscribe();
    consumer.close();
    producer.close();
    super.tearDown();
  }
Shutdown and clear Zookeeper and Kafka broker state.
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java