Package org.apache.kafka.server.policy
Interface CreateTopicPolicy
-
- All Superinterfaces:
java.lang.AutoCloseable
,Configurable
public interface CreateTopicPolicy extends Configurable, java.lang.AutoCloseable
An interface for enforcing a policy on create topics requests.
Common use cases are requiring that the replication factor,
min.insync.replicas
and/or retention settings for a topic are within an allowable range.If
create.topic.policy.class.name
is defined, Kafka will create an instance of the specified class using the default constructor and will then pass the broker configs to itsconfigure()
method. During broker shutdown, theclose()
method will be invoked so that resources can be released (if necessary).
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
CreateTopicPolicy.RequestMetadata
Class containing the create request parameters.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
validate(CreateTopicPolicy.RequestMetadata requestMetadata)
Validate the request parameters and throw aPolicyViolationException
with a suitable error message if the create topics request parameters for the provided topic do not satisfy this policy.-
Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
-
-
-
Method Detail
-
validate
void validate(CreateTopicPolicy.RequestMetadata requestMetadata) throws PolicyViolationException
Validate the request parameters and throw aPolicyViolationException
with a suitable error message if the create topics request parameters for the provided topic do not satisfy this policy. Clients will receive the POLICY_VIOLATION error code along with the exception's message. Note that validation failure only affects the relevant topic, other topics in the request will still be processed.- Parameters:
requestMetadata
- the create topics request parameters for the provided topic.- Throws:
PolicyViolationException
- if the request parameters do not satisfy this policy.
-
-