THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** * Options for {@link Admin#alterClientQuotas(Collection, AlterClientQuotasOptions)}. * * The API of this class is evolving, see {@link Admin} for details. */ public class AlterClientQuotasOptions extends AbstractOptions<AlterClientQuotasOptions> { /** * Returns whether the request should be validated without altering the configs. */ public boolean validateOnly(); /** * Sets whether the request should be validated without altering the configs. */ public AlterClientQuotasOptions validateOnly(boolean validateOnly); } /** * The result of the {@link Admin#alterClientQuotas(Collection, AlterClientQuotasOptions)} call. * * The API of this class is evolving, see {@link Admin} for details. */ @InterfaceStability.Evolving public class AlterClientQuotasResult { /** * Maps an entity to its alteration result. * * @param futures maps entity to its alteration result */ public AlterClientQuotasResult(Map<ClientQuotaEntity, KafkaFuture<Void>> futures); /** * Returns a map from quota entity to a future which can be used to check the status of the operation. */ public Map<ClientQuotaEntity, KafkaFuture<Void>> values(); /** * Returns a future which succeeds only if all quota alterations succeed. */ public KafkaFuture<Void> all(); } public interface Admin extends AutoCloseable { ... /** * Alters client quota configurations with the specified alterations. * <p> * Alterations for a single entity are atomic, but across entities is not guaranteed. The resulting * per-entity error code should be evaluated to resolve the success or failure of all updates. * <p> * The following exceptions can be anticipated when calling {@code get()} on the futures obtained from * the returned {@link AlterClientQuotasResult}: * <ul> * <li>{@link org.apache.kafka.common.errors.ClusterAuthorizationException} * If the authenticated user didn't have alter access to the cluster.</li> * <li>{@link org.apache.kafka.common.errors.InvalidRequestException} * If the request details are invalid. e.g., a configuration key was specified more than once for an entity.</li> * <li>{@link org.apache.kafka.common.errors.TimeoutException} * If the request timed out before the alterations could finish. It cannot be guaranteed whether the update * succeed or not.</li> * </ul> * <p> * This operation is supported by brokers with version 2.6.0 or higher. * * @param entries the alterations to perform * @return the AlterClientQuotasResult containing the result */ AlterClientQuotasResult alterClientQuotas(Collection<ClientQuotaAlteration> entries, AlterClientQuotasOptions options); } |
kafka-configs.sh/ConfigCommand
As a result of introducing the APIs, the ConfigCommand
will be updated to support the users and clients entity types when using the --bootstrap-server
option. The modification to ConfigCommand
was adopted in KIP-543, and usage will remain unchanged from the original --zookeeper
functionality.
kafka-client-quotas.sh/ClientQuotasCommand
...