Page History

public class QuorumInfo {
  private final String topic;
  private final List<ReplicaState> voters;
  private final List<ReplicaState> observers;

  public KafkaFuture<DescribeQuorumResponseData> result QuorumInfo(String topic, List<ReplicaState> voters, List<ReplicaState> observers) {
    this.topic = topic;
    this.voters = voters;
    this.observers = observers;
  }

  public String getTopic() {
    return topic;
  }

  public List<ReplicaState> getVoters() {
    return voters;
  }

  public List<ReplicaState> getObservers() {
    return observers;
  }

  public static class ReplicaState {
    private final int replicaId;
    private final long logEndOffset;

    public ReplicaState(int replicaId, long logEndOffset) {
      this.replicaId = replicaId;
      this.logEndOffset = logEndOffset;
    }

    public int getReplicaId() {
      return replicaId;
    }

    public long getLogEndOffset() {
      return resultlogEndOffset;
    }
  }
}