public static void alterResourceConfigs()

in src/main/java/com/epam/eco/commons/kafka/AdminClientUtils.java [953:971]

17 lines of code
2 McCabe index (conditional complexity)


    public static void alterResourceConfigs(
            AdminClient client,
            ConfigResource resource,
            Map<String, String> configs) {
        Validate.notNull(resource, "Config resource is null");
        Validate.notNull(configs, "Map of configs is null");
        Validate.noNullElements(configs.keySet(), "Map of configs contains null keys");

        Collection<AlterConfigOp> configOps = new LinkedList<>();
        configs.forEach((name, value) -> {
            if (StringUtils.isBlank(value)) {
                configOps.add(asDeleteConfigOp(name));
            } else {
                configOps.add(asSetConfigOp(name, value));
            }
        });

        incrementalAlterResourceConfigs(client, resource, configOps);
    }