public class ConfluentReplicaPlacer extends Object implements org.apache.kafka.metadata.placement.ReplicaPlacer
Constructor and Description |
---|
ConfluentReplicaPlacer(org.apache.kafka.common.utils.LogContext logContext,
org.apache.kafka.metadata.placement.ReplicaPlacer defaultPlacer,
Optional<TopicReplicaAssignorBuilder> assignorBuilder,
org.apache.kafka.metadata.placement.TopicPlacementReplicaPlacer topicPlacementReplicaPlacer) |
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.common.utils.LogContext logContext, org.apache.kafka.metadata.placement.ReplicaPlacer defaultPlacer, Optional<TopicReplicaAssignorBuilder> assignorBuilder, org.apache.kafka.metadata.placement.TopicPlacementReplicaPlacer topicPlacementReplicaPlacer)
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