public class TenantQuotaCallback extends Object implements org.apache.kafka.server.quota.ClientQuotaCallback, org.apache.kafka.common.Reconfigurable
Constructor and Description |
---|
TenantQuotaCallback() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.kafka.common.Cluster |
cluster() |
void |
configure(Map<String,?> configs) |
Double |
quotaLimit(org.apache.kafka.server.quota.ClientQuotaType quotaType,
Map<String,String> metricTags) |
Map<String,String> |
quotaMetricTags(org.apache.kafka.server.quota.ClientQuotaType quotaType,
org.apache.kafka.common.security.auth.KafkaPrincipal principal,
String clientId) |
boolean |
quotaResetRequired(org.apache.kafka.server.quota.ClientQuotaType quotaType) |
Set<String> |
reconfigurableConfigs() |
void |
reconfigure(Map<String,?> configs) |
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.
|
boolean |
updateDynamicQuotas(Map<String,Map<String,Long>> tenantClusterQuotas) |
void |
updateQuota(org.apache.kafka.server.quota.ClientQuotaType quotaType,
org.apache.kafka.server.quota.ClientQuotaEntity quotaEntity,
double newValue) |
static void |
updateQuotas(Map<String,QuotaConfig> tenantQuotas,
QuotaConfig defaultTenantQuota)
Update provisioned tenant quota configuration and/or default tenant quota.
|
static void |
updateUserQuotas(String tenant,
Map<String,QuotaConfig> userQuotas,
QuotaConfig defaultUserQuota) |
void |
validateReconfiguration(Map<String,?> configs) |
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public Set<String> reconfigurableConfigs()
reconfigurableConfigs
in interface org.apache.kafka.common.Reconfigurable
public void validateReconfiguration(Map<String,?> configs) throws org.apache.kafka.common.config.ConfigException
validateReconfiguration
in interface org.apache.kafka.common.Reconfigurable
org.apache.kafka.common.config.ConfigException
public void reconfigure(Map<String,?> configs)
reconfigure
in interface org.apache.kafka.common.Reconfigurable
public Map<String,String> quotaMetricTags(org.apache.kafka.server.quota.ClientQuotaType quotaType, org.apache.kafka.common.security.auth.KafkaPrincipal principal, String clientId)
quotaMetricTags
in interface org.apache.kafka.server.quota.ClientQuotaCallback
public Double quotaLimit(org.apache.kafka.server.quota.ClientQuotaType quotaType, Map<String,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 boolean updateDynamicQuotas(Map<String,Map<String,Long>> tenantClusterQuotas)
updateDynamicQuotas
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(Map<String,QuotaConfig> tenantQuotas, QuotaConfig defaultTenantQuota)
public static void updateUserQuotas(String tenant, Map<String,QuotaConfig> userQuotas, QuotaConfig defaultUserQuota)