Skip to content

Latest commit

 

History

History
49 lines (36 loc) · 1.22 KB

kafka-cluster-PartitionStateStore.adoc

File metadata and controls

49 lines (36 loc) · 1.22 KB
Raw

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