Class TenantClientQuotaConsumer

java.lang.Object

io.confluent.kafka.multitenant.quota.TenantClientQuotaConsumer

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.server.quota.MultiTenantQuotaConsumer

public class TenantClientQuotaConsumer
extends Object
implements org.apache.kafka.server.quota.MultiTenantQuotaConsumer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	TenantClientQuotaConsumer.State

Constructor Summary

Constructors

Constructor	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.

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)
void	configure(org.apache.kafka.connect.util.KafkaBasedLog<byte[],byte[]> log, String sessionUuid)
CompletableFuture<Void>	start()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TenantClientQuotaConsumer

public TenantClientQuotaConsumer(Map<String,?> interBrokerClientConfig,
 org.apache.kafka.common.metrics.Metrics metrics)

TenantClientQuotaConsumer

public 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. Callers must take into account that this constructor BLOCKS UNTIL THE TOPIC IS READ TO END, which could take some time, especially if retrieving the metadata for the topic from the cluster is slow (as it usually is on clusters with many partitions).

Method Details

configure

public void configure(org.apache.kafka.connect.util.KafkaBasedLog<byte[],byte[]> log,
 String sessionUuid)

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

start

public CompletableFuture<Void> start()

Specified by:

start in interface org.apache.kafka.server.quota.MultiTenantQuotaConsumer