@Test
public void testInitializedGroupStatusShouldBeGroupsDown() throws Exception {

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