Page History

public class ReplicaStatusOptions {
    
}

public class ReplicaStatusResult {
    public KafkaFuture<Map<TopicPartition, List<ReplicaStatus>>> all()
}

/** 
 * RepresentsIdentifies thea replication statusreplica of a topic partition 
 * on a particular broker.
 */ 
public class ReplicaStatusTopicPartitionReplica {
    /** Thepublic TopicPartitionReplica(String topic, aboutint whichpartition, thisshort isbroker) the{ status of */
... }
    public String topicgetTopic()
 { ... }
 /** The partition aboutpublic whichint thisgetPartition() is{ the status of */
    int partition()
    /** The broker about which this is the status of */
    int broker()... }
    public short getBroker() { ... }
}

public class ReplicaStatusOptions {
    public ReplicaStatusOptions() { ... }
    public long timeoutMs() { ... }
    public ReplicaStatusOptions timeoutMs(long timeoutMs) { ... }
}

public class ReplicaStatusResult {
    public KafkaFuture<Map<TopicPartitionReplica, List<ReplicaStatus>>> all()
    public Map<TopicPartitionReplica, KafkaFuture<ReplicaStatus>> values()
}

/** 
 * Represents the replication status of a partition 
 * on a particular broker.
 */ 
public class ReplicaStatus {
    
    /** 
     * 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()
    
}