public class CreateTopicPolicy extends Object implements org.apache.kafka.server.policy.CreateTopicPolicy, org.apache.kafka.metadata.ConfluentPartitionsPerTopicListener, org.apache.kafka.server.interceptor.Monitorable, org.apache.kafka.common.Reconfigurable
Constructor and Description |
---|
CreateTopicPolicy() |
Modifier and Type | Method and Description |
---|---|
void |
clearPending() |
void |
close() |
void |
configure(Map<String,?> configs) |
static <E> Map<E,Integer> |
frequencies(Collection<List<E>> items,
Function<E,Integer> mapper) |
void |
fullUpdate(Iterator<Map.Entry<String,Integer>> iterator,
Map<Integer,Integer> brokersToNumReplicas) |
void |
partialUpdate(String topicName,
int numPartitionsAddedOrDeleted,
int numTopicsAddedOrDeleted,
Map<Integer,List<Integer>> partitionIdToReplicasAdded,
Map<Integer,List<Integer>> partitionIdToReplicasDeleted,
boolean pending) |
Set<String> |
reconfigurableConfigs() |
void |
reconfigure(Map<String,?> configs) |
void |
registerMetrics(org.apache.kafka.common.metrics.Metrics metrics) |
void |
validate(org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata reqMetadata) |
void |
validateReconfiguration(Map<String,?> configs) |
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void registerMetrics(org.apache.kafka.common.metrics.Metrics metrics)
registerMetrics
in interface org.apache.kafka.server.interceptor.Monitorable
public void validate(org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata reqMetadata) throws org.apache.kafka.common.errors.PolicyViolationException
validate
in interface org.apache.kafka.server.policy.CreateTopicPolicy
org.apache.kafka.common.errors.PolicyViolationException
public void close()
close
in interface AutoCloseable
public void fullUpdate(Iterator<Map.Entry<String,Integer>> iterator, Map<Integer,Integer> brokersToNumReplicas)
fullUpdate
in interface org.apache.kafka.metadata.ConfluentPartitionsPerTopicListener
public void partialUpdate(String topicName, int numPartitionsAddedOrDeleted, int numTopicsAddedOrDeleted, Map<Integer,List<Integer>> partitionIdToReplicasAdded, Map<Integer,List<Integer>> partitionIdToReplicasDeleted, boolean pending)
partialUpdate
in interface org.apache.kafka.metadata.ConfluentPartitionsPerTopicListener
public void clearPending()
clearPending
in interface org.apache.kafka.metadata.ConfluentPartitionsPerTopicListener
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