private ZkUtils getZkUtilsWithNewClient() {
    ZkClient zkClient = ZkCoordinationUtilsFactory
        .createZkClient(testZkConnectionString, SESSION_TIMEOUT_MS, CONNECTION_TIMEOUT_MS);
    return new ZkUtils(
        KEY_BUILDER,
        zkClient,
        CONNECTION_TIMEOUT_MS, SESSION_TIMEOUT_MS, new NoOpMetricsRegistry());
  }
electionLatch and count together verify that:
1. the registered listeners are actually invoked by the ZkClient on the correct path
2. for a single participant failure, at-most 1 other participant is notified
samza-core/src/test/java/org/apache/samza/zk/TestZkLeaderElector.java