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 static enum QuotaType { PRDOUCER_BYTE_RATE(0), CONSUMER_BYTE_RATE(1), REQUEST_PERCENTAGE(2); QuotaType(byte id); public byte id(); } public static enum QuotaSource { SELF(0), DEFAULT(1), PARENT(2); QuotaSource(byte id); public byte id(); } public class AdminClient { public DescribeQuotasResult describeQuotas(Map<AbstractList<Resource>Map<List<Resource>, <Collection<QuotaType>>, DescribeQuotasOptions options); public AlterQuotasResult alterQuotas(Map<AbstractList<Resource>Map<List<Resource>, <Collection<Quota>> configs, AlterQuotasOptions options); } public class DescribeQuotasOptions { public DescribeQuotasOptions timeoutMs(Integer timeout); } public class DescribeQuotasResult { public Map<AbstractList<Resource>Map<List<Resource>, <KafkaFuture<Collection<Quota>>> values(); } public class AlterQuotasOptions { public AlterQuotasOptions timeoutMs(Integer timeout); public AlterQuotasOptions validateOnly(boolean validateOnly); } public class AlterQuotasResult { public Map<AbstractList<Resource>Map<List<Resource>, <KafkaFuture<Void>> results(); } |
...
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<AbstractList<Resource>Map<List<Resource>, <Collection<QuotaType>> quotaSettings); public DescribeQuotasRequest build(short version); } public DescribeQuotasRequest(short version, Map<AbstractList<Resource>Map<List<Resource>, <Collection<QuotaType>> quotaSettings); public DescribeQuotasRequest(Struct struct, short version); public Map<AbstractList<Resource>Map<List<Resource>, Collection<QuotaType>> quotaTypes(); } public class DescribeQuotasResponse extends AbstractResponse { public static Schema[] schemaVersions(); public DescribeQuotasResponse(int throttleTimeMs, Map<AbstractList<Resource>Map<List<Resource>, QuotaCollection> quotas); public DescribeQuotasResponse(Struct struct); public Map<AbstractList<Resource>Map<List<Resource>, QuotaCollection> quotas(); } public class AlterQuotasRequest extends AbstractRequest { public static Schema[] schemaVersions(); public static class Builder extends AbstractRequest.Builder { public Builder(Map<AbstractList<Resource>Map<List<Resource>, QuotaCollection> quotaSettings); public DescribeQuotasRequest build(short version); } public AlterQuotasRequest(short version, Map<AbstractList<Resource>Map<List<Resource>, QuotaCollection> quotas, boolean validateOnly); public AlterQuotasRequest(Struct struct, short version); public Map<AbstractList<Resource>Map<List<Resource>, QuotaCollection> quotas(); } public class AlterQuotasResponse extends AbstractResponse { public static Schema[] schemaVersions(); public AlterQuotasRequest(short version, Map<AbstractList<Resource>Map<List<Resource>, ApiError> quotas, boolean validateOnly); public AlterQuotasRequest(Struct struct, short version); public Map<AbstractList<Resource>Map<List<Resource>, ApiError> errors(); public int throttleTimeMs(); } |
...