Class QuorumInfo

java.lang.Object

org.apache.kafka.clients.admin.QuorumInfo

public class QuorumInfo
extends Object

This class is used to describe the state of the quorum received in DescribeQuorumResponse.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	QuorumInfo.Node
static class	QuorumInfo.ReplicaState

Constructor Summary

Constructors

Constructor	Description
QuorumInfo(int leaderId, long leaderEpoch, long highWatermark, List<QuorumInfo.ReplicaState> voters, List<QuorumInfo.ReplicaState> observers, Map<Integer, QuorumInfo.Node> nodes)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
long	highWatermark()
long	leaderEpoch()
int	leaderId()
Map<Integer, QuorumInfo.Node>	nodes()
List<QuorumInfo.ReplicaState>	observers()
String	toString()
List<QuorumInfo.ReplicaState>	voters()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

QuorumInfo

public QuorumInfo(int leaderId,
 long leaderEpoch,
 long highWatermark,
 List<QuorumInfo.ReplicaState> voters,
 List<QuorumInfo.ReplicaState> observers,
 Map<Integer, QuorumInfo.Node> nodes)

Method Details

leaderId

public int leaderId()

leaderEpoch

public long leaderEpoch()

highWatermark

public long highWatermark()

voters

public List<QuorumInfo.ReplicaState> voters()

observers

public List<QuorumInfo.ReplicaState> observers()

nodes

public Map<Integer, QuorumInfo.Node> nodes()

Returns:

The voter nodes in the Raft cluster, or an empty map if KIP-853 is not enabled.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object