public static class ConnectionQuota.Builder<Entity> extends Object
Constructor and Description |
---|
Builder(org.apache.kafka.common.metrics.Metrics metrics) |
Modifier and Type | Method and Description |
---|---|
ConnectionQuota<Entity> |
build() |
ConnectionQuota.Builder<Entity> |
setCalculateDefaultMaxConnectionRate(Supplier<Double> calculateDefaultMaxConnectionRate) |
ConnectionQuota.Builder<Entity> |
setCreateListenerConnectionQuotaEntity(BiFunction<Entity,org.apache.kafka.common.network.ListenerName,kafka.network.ListenerConnectionQuotaEntity> createListenerConnectionQuotaEntity) |
ConnectionQuota.Builder<Entity> |
setCreateQuotaEntity(Function<Entity,kafka.network.ConnectionQuotaEntity> createQuotaEntity) |
ConnectionQuota.Builder<Entity> |
setDefaultMaxConnections(int defaultMaxConnections) |
ConnectionQuota.Builder<Entity> |
setEntityMetricTag(String entityMetricTag) |
ConnectionQuota.Builder<Entity> |
setMaxConnectionsOverride(Map<Entity,Integer> maxConnectionsOverride) |
ConnectionQuota.Builder<Entity> |
setMetricValueToEntity(Function<String,Entity> metricValueToEntity) |
public ConnectionQuota.Builder<Entity> setMaxConnectionsOverride(Map<Entity,Integer> maxConnectionsOverride)
public ConnectionQuota.Builder<Entity> setDefaultMaxConnections(int defaultMaxConnections)
public ConnectionQuota.Builder<Entity> setCreateQuotaEntity(Function<Entity,kafka.network.ConnectionQuotaEntity> createQuotaEntity)
public ConnectionQuota.Builder<Entity> setCreateListenerConnectionQuotaEntity(BiFunction<Entity,org.apache.kafka.common.network.ListenerName,kafka.network.ListenerConnectionQuotaEntity> createListenerConnectionQuotaEntity)
public ConnectionQuota.Builder<Entity> setCalculateDefaultMaxConnectionRate(Supplier<Double> calculateDefaultMaxConnectionRate)
public ConnectionQuota.Builder<Entity> setEntityMetricTag(String entityMetricTag)
public ConnectionQuota.Builder<Entity> setMetricValueToEntity(Function<String,Entity> metricValueToEntity)
public ConnectionQuota<Entity> build()