Page History

/**
 * This class defines a view of a cluster that the partition placer can see, such as the current assignment
 * or broker -> rack mappings.
 */
public class ClusterView {

    private final Map<TopicPartition, List<Integer>> partitionAssignments;
    private final Iterator<UsableBroker> usableBrokers;

    public ClusterView(Map<TopicPartition, List<Integer>> partitionAssignments, List<BrokerInfo> brokerInfos) {
        this.partitionAssignments = partitionAssignments;
        this.brokerInfos = brokerInfos;
    }

    public Map<TopicPartition, List<Integer>> topicAssignments() {
        return Collections.unmodifiableMap(partitionAssignments);
    }

/**
 * This class defines a view of a cluster that the partition assignor can see, such as the current assignment
 * or broker -> rack mappings.
 */
public class ClusterView {

    private final Map<TopicPartition, List<Integer>> partitionAssignments;
    private final List<BrokerInfo> brokerInfos;

    public ClusterView(Map<TopicPartition, List<Integer>> partitionAssignments, List<BrokerInfo> brokerInfos() {
        return this.partitionAssignments = partitionAssignments;
        this.brokerInfos = brokerInfosCollections.unmodifiableList(brokerInfos);
    }

    public Map<TopicPartition, List<Integer>> topicAssignments() {
        return Collections.unmodifiableMap(partitionAssignments);
    }

    public List<BrokerInfo> brokerInfos() {
        return Collections.unmodifiableList(brokerInfos);
    }
}

    /**
     * Create a partitions assignment according to the partition assignment strategy set in the cluster. It will use the
     * brokers and racks available to the cluster to create an assignment given the number of partitions and the
     * replication factor.
     * @param numPartitions is the number of partitions of the topic to act on

    /**
     * Create@param a partitions assignment according to replicationFactor is the partitionreplication assignment strategy set infactor of the cluster.topic It will use thein action
     * brokers@return anda racksresult availableobject tocontaining the cluster to create an assignment given the number of partitions and theassignment.
     */
     * replication factor.CreateReplicaPlacementResult createReplicaPlacement(int numPartitions, short replicationFactor);

    /**
 * @param numPartitions is the* numberCreate ofa partitions ofassignment the topicaccording to actthe on
partition placement strategy set in * @param replicationFactor is the replication factor of the topic in action
     * @return a result object containing the partition -> brokerId[] mapping.the cluster. It will use the
     * brokers and racks available to the cluster to create an assignment given the number of partitions and the
     */
    CreateReplicaAssignmentResult createReplicaAssignment(int numPartitions, short replicationFactor);

    /** replication factor. In an extra options parameter we can define a starting partition and replication factor.
     * Create@param anumPartitions partitions assignment according to is the partitionnumber assignmentof strategypartitions set inof the cluster.topic Itto willact use theon
     * brokers@param andreplicationFactor racksis available to the cluster to create an assignment given the numberreplication factor of partitionsthe topic andin theaction
     * @param options replicationis factor.the Inparameter anwhere extra options parameter we can definebe aset startingto partitionfurther andcontrol replicationreplica factorplacement.
     * @param@return numPartitionsa isresult theobject numbercontaining ofthe partitionspartition of the topic to act on-> brokerId[] mapping.
     */
 @param replicationFactor is theCreateReplicaPlacementResult replication factor of the topic in action
  createReplicaPlacement(int numPartitions, short replicationFactor,
   * @param options is the parameter where extra options like starting partition number or replication factor can be set.
     * @return a result object containing the partition -> brokerId[] mapping.
       */
    CreateReplicaAssignmentResult createReplicaAssignment(int numPartitions, short replicationFactor,
        CreateReplicaPlacementOptions options);

public class CreateReplicaPlacementResult {

    private KafkaFuture<List<List<Integer>>> future;

    CreateReplicaPlacementResult(KafkaFuture<List<List<Integer>>> future) {
        this.future = future;
    }

    public KafkaFuture<List<List<Integer>>> placements() {
        return future;
    CreateReplicaAssignmentOptions options);}
}