QuorumState¶
QuorumState is used by KafkaRaftClient to...FIXME
Creating Instance¶
QuorumState takes the following to be created:
- Local ID
- Voters
- controller.quorum.election.timeout.ms
- controller.quorum.fetch.timeout.ms
-
QuorumStateStore -
Time -
LogContext -
Random
QuorumState is created when:
KafkaRaftClientis created
voters¶
Set<Integer> voters
QuorumState is given quorum voters (their IDs) when created based on controller.quorum.voters configuration property.