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.
|
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.
|
String |
toString() |
public RequestMetadata(String topic, Integer numPartitions, Short replicationFactor, Map<Integer,List<Integer>> replicasAssignments, Map<String,String> configs)
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 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.