KafkaRaftClient¶

KafkaRaftClient is a RaftClient.

Creating Instance¶

KafkaRaftClient takes the following to be created:

• RecordSerde<T>
• NetworkChannel
• RaftMessageQueue
• ReplicatedLog
• QuorumStateStore
• MemoryPool
• Time
• Metrics
• ExpirationService
• fetchMaxWaitMs (500 ms)
• Cluster ID
• Node ID
• LogContext
• Random
• RaftConfig

KafkaRaftClient is created when:

• KafkaRaftManager is requested to build a KafkaRaftClient

QuorumStateStore¶

KafkaRaftClient is given a QuorumStateStore when created.

The QuorumStateStore is a FileBasedStateStore with the quorum-state state file in the dataDir.

poll¶

void poll()

poll...FIXME

poll is used when:

• RaftIoThread is requested to doWork

pollListeners¶

void pollListeners()

pollListeners...FIXME

processRegistration¶

void processRegistration(
  Registration<T> registration)

processRegistration...FIXME