@Test(expected = ConfigException.class)
public void testMissingStreamsParam() throws Exception {

    Map<String, String> map = new HashMap<String, String>();
    ESPushTaskConfig.getStreamMap(new MapConfig(map));
}