Skip to content

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: