RequestHandlerHelper¶

Creating Instance¶

RequestHandlerHelper takes the following to be created:

• RequestChannel
• QuotaManagers
• Time
• Log Prefix

RequestHandlerHelper is created when:

• ControllerApis is created (requestHelper)
• KafkaApis is created

onLeadershipChange¶

onLeadershipChange(
  groupCoordinator: GroupCoordinator,
  txnCoordinator: TransactionCoordinator,
  updatedLeaders: Iterable[Partition],
  updatedFollowers: Iterable[Partition]): Unit

onLeadershipChange...FIXME

onLeadershipChange is used when:

• BrokerServer is requested to start up
• KafkaApis is requested to handleLeaderAndIsrRequest
• BrokerMetadataListener is requested to handleCommits and execCommits