@Test
public void testInitializedGroupStatusShouldBeInitilized() throws Exception {

    doNothing().when(zkUtils).createEphemeralZNode(anyString(), any(byte[].class));
    when(zkUtils.existZNode(contains("group1"))).thenReturn(true);
    when(zkUtils.existZNode(contains("group2"))).thenReturn(true);
    assertEquals( STREAMING.ZK_EPHEMERAL_NODE_STATUS_INITIALIZED, clusterSyncManager.initializedGroupStatus());
}