PartitionStateStore

PartitionStateStore is the abstraction of state stores for Partitions to fetch topic configuration and expand or shrink in-sync replicas.

Note
 ZkPartitionStateStore is the default and only known PartitionStateStore in Apache Kafka.
Table 1. PartitionStateStore Contract
Method Description

expandIsr

 
expandIsr(
  controllerEpoch: Int,
  leaderAndIsr: LeaderAndIsr): Option[Int]

Used when Partition is requested to expandIsr

fetchTopicConfig

 
fetchTopicConfig(): Properties

Used when Partition is requested to createLog

shrinkIsr

 
shrinkIsr(
  controllerEpoch: Int,
  leaderAndIsr: LeaderAndIsr): Option[Int]

Used when Partition is requested to shrinkIsr

results matching ""

    No results matching ""