Page History

public interfaceclass AlterConfigOp {

    public enum OpType {
        SET((byte) 0),  ConfigResource resource(DELETE((byte) 1), APPEND((byte) 2), SUBTRACT((byte) 3);
}

public class SetConfigOp extends AlterConfigOp {
  public SetConfigOp(ConfigResource resource, String value);
}

public class DeleteConfigOp extends AlterConfigOp {
  public DeleteConfigOp(SConfigResource resource);
}

public class AppendConfigOp extends AlterConfigOp {
  public AppendConfigOp(ConfigResource resource, String value);
}

public class SubtractConfigOp extends AlterConfigOp {
  public SubtractConfigOp(ConfigResource resource, String value);

        private static final Map<Byte, OpType> OP_TYPES = Collections.unmodifiableMap(
                Arrays.stream(values()).collect(Collectors.toMap(OpType::id, Function.identity()))
        );

        private final byte id;

        OpType(final byte id) {
            this.id = id;
        }

        public byte id() {
            return id;
        }

        public static OpType forId(final byte id) {
            return OP_TYPES.get(id);
        }
    }

    private final ConfigResource configResource;
    private final ConfigEntry configEntry;
    private final OpType opType;

    public AlterConfigOp(ConfigResource configResource, ConfigEntry configEntry,
                         OpType operationType) {
        this.configResource = configResource;
        this.configEntry = configEntry;
        this.opType =  operationType;
    }
}

public IncrementalAlterConfigsResult incrementalAlterConfigsalterConfigs(
    Collection<AlterConfigOp> ops,
    final IncrementalAlterConfigsOptions options);

@InterfaceStability.Evolving
public class IncrementalAlterConfigsResult {
    private final Map<ConfigResourceMap<AlterConfigOp, KafkaFuture<Void>> futures;

    IncrementalAlterConfigsResult(Map<ConfigResourceMap<AlterConfigOp, KafkaFuture<Void>> futures) {
        this.futures = futures;
    }

    /**
     * Return a map from resources to futures which can be used to check the status of the operation on each resource.
     */
    public Map<ConfigResourceMap<AlterConfigOp, KafkaFuture<Void>> values() {
        return futures;
    }

    /**
     * Return a future which succeeds only if all the alter configs operations succeed.
     */
    public KafkaFuture<Void> all() {
        return KafkaFuture.allOf(futures.values().toArray(new KafkaFuture[0]));
    }
}

IncrementalAlterConfigsResponse (Version: 0) => [responses]   
  responsesresources => resource_type resource_name [configs]
  resource_type => INT8
  resource_name => STRING
  configs => config_name config_op config_value error_code error_message
  config_name => STRING
  resourceconfig_typeop => INT8
   resourceconfig_namevalue => NULLABLE_STRING
  error_code => INT16
  error_message => NULLABLE_STRING