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 |
close() |
void |
configure(Map<String,?> configs) |
void |
fullUpdate(Iterator<Map.Entry<String,Integer>> iterator) |
void |
partialUpdate(String topicName,
int numPartitionsChange) |
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)
fullUpdate
in interface org.apache.kafka.metadata.ConfluentPartitionsPerTopicListener
public void partialUpdate(String topicName, int numPartitionsChange)
partialUpdate
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