Page History

public class ReplicaStatusResult {
    public KafkaFuture<Map<TopicPartition, List<ReplicaStatus>>> all()
}
/** 
 * Represents the replication status of a partition 
 * on a particular broker.
 */ 
public class ReplicaStatus {
    /** The topic about which this is the status of */
    String topic()
    /** The partition about which this is the status of */
    int gpartitionpartition()
    /** The broker about which this is the status of */
    int broker()
    
    /** 
     * The time (as milliseconds since the epoch) that 
     * this status data was collected. In general this may
     * be some time before the replicaStatus() request time.
     */
    public long statusTime()
    
    /** 
     * The number of messages that the replica on this broker is behind
     * the leader.
     */
    public long lag()
    
}

AlterTopicsRequest => [AlteredTopic]
  AlteredTopic => Topic, NumPartitions, ReplicationFactor, PartitionAssignment
    Topic => string               ; the topic name
    NumPartitions => int32        ; the number of partitions
    ReplicationFactor => int32int16    ; the replication factor
    PartitionAssignment => PartitionId Brokers
      PartitionId =>int32         ; the partition id
      Brokers => [int32]          ; the ids of the assigned brokers for this partition