RaftIoThread¶
RaftIoThread is an uninterruptible ShutdownableThread with the following name (based on the threadNamePrefix):
[threadNamePrefix]-io-thread
Creating Instance¶
RaftIoThread takes the following to be created:
- KafkaRaftClient
- Thread Name Prefix
-
FaultHandler
RaftIoThread is created alongside KafkaRaftManager.
doWork¶
ShutdownableThread
doWork(): Unit
doWork is part of the ShutdownableThread abstraction.
doWork requests the KafkaRaftClient to poll.