THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
public static class Quota {
public QuotaType type();
public double value();
public QuotaSource source();
}
public enum QuotaType {
PRODUCER_BYTE_RATE((byte) 0, "producer_byte_rate"),
CONSUMER_BYTE_RATE((byte) 1, "consumer_byte_rate"),
REQUEST_PERCENTAGE((byte) 2, "request_percentage");
QuotaType(byte id, String name);
public byte id();
public String quotaName();
}
public enum QuotaSource {
CLIENT_OF_USER((byte) 0, "Client of user"),
DEFAULT_CLIENT_OF_USER((byte) 1, "Default client of user"),
USER((byte) 2, "User"),
CLIENT_OF_DEFAULT_USER((byte) 3, "Client of default user"),
DEFAULT_CLIENT_OF_DEFAULT_USER((byte) 4, "Default client of default user"),
DEFAULT_USER((byte) 5, "Default user"), CLIENT((byte) 6, "Client"),
DEFAULT_CLIENT((byte) 7, "Default client");
QuotaSource(byte id, String description);
public byte id();
public String description();
}
public class AdminClient {
public DescribeQuotasResult describeQuotas(Map<List<ConfigResource>, <Collection<QuotaType>>Collection<QuotaType>>, DescribeQuotasOptions options);
public AlterQuotasResult alterQuotas(Map<List<ConfigResource>, <Collection<Quota>>Collection<Quota>> configs, AlterQuotasOptions options);
}
public class DescribeQuotasOptions {
public DescribeQuotasOptions timeoutMs(Integer timeout);
}
public class DescribeQuotasResult {
public Map<List<Resource>, <KafkaFuture<Collection<Quota>>>KafkaFuture<Collection<Quota>>> values();
}
public class AlterQuotasOptions {
public AlterQuotasOptions timeoutMs(Integer timeout);
public AlterQuotasOptions validateOnly(boolean validateOnly);
}
public class AlterQuotasResult {
public Map<List<Resource>, <KafkaFuture<Void>>KafkaFuture<Void>> results();
} |
Request API
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class QuotaCollection {
public QuotaCollection(ApiError error, Collection<Quota> entries);
public QuotaCollection(Collection<Quota> entries);
public ApiError error();
public Collection<Quota> entries();
}
public class DescribeQuotasRequest extends AbstractRequest {
public static Schema[] schemaVersions();
public static DescribeQuotasRequest parse(ByteBuffer buffer, short version);
public static class Builder extends AbstractRequest.Builder {
public Builder(Map<List<Resource>, <Collection<QuotaType>>Collection<QuotaType>> quotaSettings);
public DescribeQuotasRequest build(short version);
}
public DescribeQuotasRequest(short version, Map<List<Resource>, <Collection<QuotaType>>Collection<QuotaType>> quotaSettings);
public DescribeQuotasRequest(Struct struct, short version);
public Map<List<Resource>, Collection<QuotaType>> quotaTypes();
}
public class DescribeQuotasResponse extends AbstractResponse {
public static Schema[] schemaVersions();
public DescribeQuotasResponse(int throttleTimeMs, Map<List<Resource>Map<List<ConfigResource>, QuotaCollection> quotasKafkaFuture<Collection<Quota>>>);
public DescribeQuotasResponse(Struct struct);
public Map<List<Resource>, QuotaCollection> quotas();
}
public class AlterQuotasRequest extends AbstractRequest {
public static Schema[] schemaVersions();
public static class Builder extends AbstractRequest.Builder {
public Builder(Map<List<Resource>, QuotaCollection> quotaSettings);
public DescribeQuotasRequest build(short version);
}
public AlterQuotasRequest(short version, Map<List<Resource>, QuotaCollection> quotas, boolean validateOnly);
public AlterQuotasRequest(Struct struct, short version);
public Map<List<Resource>, QuotaCollection> quotas();
}
public class AlterQuotasResponse extends AbstractResponse {
public static Schema[] schemaVersions();
public AlterQuotasRequest(short version, Map<List<Resource>, ApiError> quotas, boolean validateOnly);
public AlterQuotasRequest(Struct struct, short version);
public Map<List<Resource>, ApiError> errors();
public int throttleTimeMs();
}
|
...