public class TenantQuotaCallback
extends java.lang.Object
implements org.apache.kafka.server.quota.ClientQuotaCallback
Constructor and Description |
---|
TenantQuotaCallback() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.kafka.common.Cluster |
cluster() |
void |
configure(java.util.Map<java.lang.String,?> configs) |
static TenantPartitionAssignor |
partitionAssignor(java.util.Map<java.lang.String,?> configs) |
java.lang.Double |
quotaLimit(org.apache.kafka.server.quota.ClientQuotaType quotaType,
java.util.Map<java.lang.String,java.lang.String> metricTags) |
java.util.Map<java.lang.String,java.lang.String> |
quotaMetricTags(org.apache.kafka.server.quota.ClientQuotaType quotaType,
org.apache.kafka.common.security.auth.KafkaPrincipal principal,
java.lang.String clientId) |
boolean |
quotaResetRequired(org.apache.kafka.server.quota.ClientQuotaType quotaType) |
void |
removeQuota(org.apache.kafka.server.quota.ClientQuotaType quotaType,
org.apache.kafka.server.quota.ClientQuotaEntity quotaEntity) |
boolean |
updateClusterMetadata(org.apache.kafka.common.Cluster cluster)
Handle metadata update.
|
void |
updateQuota(org.apache.kafka.server.quota.ClientQuotaType quotaType,
org.apache.kafka.server.quota.ClientQuotaEntity quotaEntity,
double newValue) |
static void |
updateQuotas(java.util.Map<java.lang.String,QuotaConfig> tenantQuotas,
QuotaConfig defaultTenantQuota)
Update provisioned tenant quota configuration and/or default tenant quota.
|
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public java.util.Map<java.lang.String,java.lang.String> quotaMetricTags(org.apache.kafka.server.quota.ClientQuotaType quotaType, org.apache.kafka.common.security.auth.KafkaPrincipal principal, java.lang.String clientId)
quotaMetricTags
in interface org.apache.kafka.server.quota.ClientQuotaCallback
public java.lang.Double quotaLimit(org.apache.kafka.server.quota.ClientQuotaType quotaType, java.util.Map<java.lang.String,java.lang.String> metricTags)
quotaLimit
in interface org.apache.kafka.server.quota.ClientQuotaCallback
public void updateQuota(org.apache.kafka.server.quota.ClientQuotaType quotaType, org.apache.kafka.server.quota.ClientQuotaEntity quotaEntity, double newValue)
updateQuota
in interface org.apache.kafka.server.quota.ClientQuotaCallback
public void removeQuota(org.apache.kafka.server.quota.ClientQuotaType quotaType, org.apache.kafka.server.quota.ClientQuotaEntity quotaEntity)
removeQuota
in interface org.apache.kafka.server.quota.ClientQuotaCallback
public boolean quotaResetRequired(org.apache.kafka.server.quota.ClientQuotaType quotaType)
quotaResetRequired
in interface org.apache.kafka.server.quota.ClientQuotaCallback
public boolean updateClusterMetadata(org.apache.kafka.common.Cluster cluster)
updateClusterMetadata
in interface org.apache.kafka.server.quota.ClientQuotaCallback
public org.apache.kafka.common.Cluster cluster()
public void close()
close
in interface org.apache.kafka.server.quota.ClientQuotaCallback
public static void updateQuotas(java.util.Map<java.lang.String,QuotaConfig> tenantQuotas, QuotaConfig defaultTenantQuota)
public static TenantPartitionAssignor partitionAssignor(java.util.Map<java.lang.String,?> configs)