public static class CreateTopicPolicy.RequestMetadata extends Object
| Constructor and 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 and TopicType.STANDARD. |
RequestMetadata(String topic, Integer numPartitions, Short replicationFactor, Map<Integer,List<Integer>> replicasAssignments, Map<String,String> configs, TopicType topicType)Create an instance of this class with the provided parameters. |
| Modifier and Type | Method and Description |
|---|---|
Map<String,String> | configs()Return topic configs in the request, not including broker defaults. |
boolean | equals(Object o) |
int | hashCode() |
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. |
TopicType | topicType()Return the type of the topic, e.g. |
String | toString() |
public RequestMetadata(String topic, Integer numPartitions, Short replicationFactor, Map<Integer,List<Integer>> replicasAssignments, Map<String,String> configs)
TopicType.STANDARD. This constructor is public to make testing of CreateTopicPolicy implementations easier.topic - the name of the topic to create.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.public RequestMetadata(String topic, Integer numPartitions, Short replicationFactor, Map<Integer,List<Integer>> replicasAssignments, Map<String,String> configs, TopicType topicType)
CreateTopicPolicy implementations easier.topic - the name of the topic to create.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.topicType - the type of the topic, e.g. STANDARD, FREIGHT, etc.public String topic()
public Integer numPartitions()
public Short replicationFactor()
public Map<Integer,List<Integer>> replicasAssignments()
public Map<String,String> configs()
configure() method of the policy implementation.public TopicType topicType()