public class TenantClientQuotaConsumer extends Object implements org.apache.kafka.server.quota.MultiTenantQuotaConsumer
Modifier and Type | Class and Description |
---|---|
static class |
TenantClientQuotaConsumer.State |
Constructor and Description |
---|
TenantClientQuotaConsumer(Map<String,?> interBrokerClientConfig,
org.apache.kafka.common.metrics.Metrics metrics) |
TenantClientQuotaConsumer(Map<String,?> interBrokerClientConfig,
org.apache.kafka.common.metrics.Metrics metrics,
org.apache.kafka.common.utils.Time time)
Creates a new TenantClientQuotaConsumer, that reads user quotas from the sync pipeline topic and applies them.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(org.apache.kafka.connect.util.KafkaBasedLog<byte[],byte[]> log,
String sessionUuid) |
void |
configure(Map<String,?> configs) |
CompletableFuture<Void> |
start() |
public TenantClientQuotaConsumer(Map<String,?> interBrokerClientConfig, org.apache.kafka.common.metrics.Metrics metrics)
public TenantClientQuotaConsumer(Map<String,?> interBrokerClientConfig, org.apache.kafka.common.metrics.Metrics metrics, org.apache.kafka.common.utils.Time time)
public void configure(org.apache.kafka.connect.util.KafkaBasedLog<byte[],byte[]> log, String sessionUuid)
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void close()
close
in interface Closeable
close
in interface AutoCloseable
public CompletableFuture<Void> start()
start
in interface org.apache.kafka.server.quota.MultiTenantQuotaConsumer