class ESPushTaskConfig {

    public static Map<String,ESIndexSpec> getStreamMap(Config config) {
        //Get list of stream
        List<String> streams = config.getList(CFG_ES_STREAMS);
        return streams.stream()
                .collect(Collectors.toMap(Function.identity(), stream -> getStreamConfig(stream, config)));
    }

}