public static void disableMockConsumerCache() {
    useCachedConsumer = false;
    mockConsumer = null;
  }
Helper for creating mock CoordinatorStreamConsumer and
CoordinatorStreamConsumer. The CoordinatorStreamConsumer is meant to just
forward all configs to JobCoordinator, which is useful for mocking in unit
tests.
samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamSystemFactory.java