  @Test(timeout = 120000)
  public void zookeeperReady() throws Exception {

    assertThat(
        ClusterStatus.isZookeeperReady(this.kafka.getZookeeperConnectString(), 10000))
        .isTrue();
  }