@Override
  protected String prefix() {
    return "test_ZK_failure_";
  }
Failure tests:
ZK unavailable.
One processor fails in process.
samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorFailures.java