@Before
  public void testSetup() {
    testZkConnectionString = "127.0.0.1:" + zkServer.getPort();
    try {
      testZkUtils = getZkUtilsWithNewClient("testZkUtils");
    } catch (Exception e) {
      Assert.fail("Client connection setup failed. Aborting tests..");
    }
    testZkUtils.connect();
  }
The ZkProcessorLatch uses a shared Znode as a latch. Each participant await existence of a target znode under the
shared latch, which is a persistent, sequential target znode with value (latchSize - 1). latchSize is the minimum
number of participants that need to join the latch.
samza-core/src/test/java/org/apache/samza/zk/TestZkProcessorLatch.java