Page History

public classinterface AlterConfigOp {

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

        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;
    }
ConfigResource resource();
}

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);
}

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

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

    IncrementalAlterConfigsResult(Map<AlterConfigOpMap<ConfigResource, 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<AlterConfigOpMap<ConfigResource, 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]   
  resourcesresponses => resource_type resource_name [configs]
  resource_type => INT8
  resource_name => STRING
  configs => config_name config_op config_value error_code error_message
  configresource_nametype => STRINGINT8
  config_op => INT8
  config_valueresource_name => NULLABLE_STRING
  error_code => INT16
  error_message => NULLABLE_STRING