...
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 { SELFCLIENT_IN_USER(0), DEFAULT_CLIENT_IN_USER(1), PARENT(2USER(2), CLIENT_IN_DEFAULT_USER(3), DEFAULT_CLIENT_IN_DEFAULT_USER(4), DEFAULT_USER(5), CLIENT(6), DEFAULT_CLIENT(7); QuotaSource(byte id); public byte id(); } public class AdminClient { public DescribeQuotasResult describeQuotas(Map<List<Resource>, <Collection<QuotaType>>, DescribeQuotasOptions options); public AlterQuotasResult alterQuotas(Map<List<Resource>, <Collection<Quota>> configs, AlterQuotasOptions options); } public class DescribeQuotasOptions { public DescribeQuotasOptions timeoutMs(Integer timeout); } public class DescribeQuotasResult { public 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<List<Resource>, <KafkaFuture<Void>> results(); } |
...