@Test(expected = org.apache.samza.SamzaException.class)
  public void testZkUnavailable() {
    map.put(ZkConfig.ZK_CONNECT, "localhost:2222"); // non-existing zk
    map.put(ZkConfig.ZK_CONNECTION_TIMEOUT_MS, "3000"); // shorter timeout
    CountDownLatch startLatch = new CountDownLatch(1);
    createStreamProcessor("1", map, startLatch, null); // this should fail with timeout exception
    Assert.fail("should've thrown an exception");
  }
Failure tests:
ZK unavailable.
One processor fails in process.
samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorFailures.java