Package org.apache.kafka.server.policy

Class CreateTopicPolicy.RequestMetadata

java.lang.Object

org.apache.kafka.server.policy.CreateTopicPolicy.RequestMetadata

Enclosing interface:

CreateTopicPolicy

public static class CreateTopicPolicy.RequestMetadata
extends Object

Class containing the create request parameters.

Constructor Summary

Constructors

Constructor	Description
RequestMetadata(String topic, Integer numPartitions, Short replicationFactor, Map<Integer,List<Integer>> replicasAssignments, Map<String,String> configs)	Create an instance of this class with the provided parameters.

Method Summary

Modifier and Type	Method	Description
Map<String,String>	configs()	Return topic configs in the request, not including broker defaults.
Integer	numPartitions()	Return the number of partitions to create or null if replicaAssignments is not null.
Map<Integer,List<Integer>>	replicasAssignments()	Return a map from partition id to replica (broker) ids or null if numPartitions and replicationFactor are set instead.
Short	replicationFactor()	Return the number of replicas to create or null if replicaAssignments is not null.
String	topic()	Return the name of the topic to create.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

RequestMetadata

public RequestMetadata(String topic,
Integer numPartitions,
Short replicationFactor,
Map<Integer,List<Integer>> replicasAssignments,
Map<String,String> configs)

Create an instance of this class with the provided parameters. This constructor is public to make testing of CreateTopicPolicy implementations easier.

Parameters:

topic - the name of the topic to created.

numPartitions - the number of partitions to create or null if replicasAssignments is set.

replicationFactor - the replication factor for the topic or null if replicaAssignments is set.

replicasAssignments - replica assignments or null if numPartitions and replicationFactor is set. The assignment is a map from partition id to replica (broker) ids.

configs - topic configs for the topic to be created, not including broker defaults. Broker configs are passed via the configure() method of the policy implementation.

Method Details

topic

public String topic()

Return the name of the topic to create.

numPartitions

public Integer numPartitions()

Return the number of partitions to create or null if replicaAssignments is not null.

replicationFactor

public Short replicationFactor()

Return the number of replicas to create or null if replicaAssignments is not null.

replicasAssignments

public Map<Integer,List<Integer>> replicasAssignments()

Return a map from partition id to replica (broker) ids or null if numPartitions and replicationFactor are set instead.

configs

public Map<String,String> configs()

Return topic configs in the request, not including broker defaults. Broker configs are passed via the configure() method of the policy implementation.

toString

public String toString()

Overrides:

toString in class Object