public class ConfluentReplicaPlacer extends Object implements org.apache.kafka.metadata.placement.ReplicaPlacer
Constructor and Description |
---|
ConfluentReplicaPlacer(org.apache.kafka.metadata.placement.ReplicaPlacer defaultPlacer,
TopicReplicaAssignorBuilder assignorBuilder) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.metadata.placement.TopicAssignment |
place(org.apache.kafka.metadata.placement.PlacementSpec placement,
org.apache.kafka.metadata.placement.ClusterDescriber cluster) |
public ConfluentReplicaPlacer(org.apache.kafka.metadata.placement.ReplicaPlacer defaultPlacer, TopicReplicaAssignorBuilder assignorBuilder)
public org.apache.kafka.metadata.placement.TopicAssignment place(org.apache.kafka.metadata.placement.PlacementSpec placement, org.apache.kafka.metadata.placement.ClusterDescriber cluster) throws org.apache.kafka.common.errors.InvalidReplicationFactorException
place
in interface org.apache.kafka.metadata.placement.ReplicaPlacer
org.apache.kafka.common.errors.InvalidReplicationFactorException