@After
  @Override
  public void tearDown() {
    topicConsumerMap.values().forEach(c -> {
      c.unsubscribe();
      c.close();
    });
    super.tearDown();
  }
Container for any necessary context created during runApplication. Allows tests to access objects created within
runApplication in order to do verification.
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTestHarness.java