kafka源碼研究之分區狀態

      kafka的分區狀態經過PartitionStateMachine來進行維護,下面經過源碼來對這個類進行探究：html   一   該類成員變量部分：緩存 private val controllerContext = controller.controllerContext private val controllerId = controller.config.brokerId p

>>阅读原文<<