AbstractControlRequest¶

AbstractControlRequest is an extension of the AbstractRequest abstraction for controller requests that KafkaController uses to propage broker and partition state changes to brokers.

Contract¶

brokerEpoch¶

long brokerEpoch()

Used when:

• KafkaApis is requested to handleLeaderAndIsrRequest, handleStopReplicaRequest, handleUpdateMetadataRequest

controllerEpoch¶

int controllerEpoch()

Used when:

• KafkaApis is requested to handleStopReplicaRequest
• ReplicaManager is requested to maybeUpdateMetadataCache, becomeLeaderOrFollower
• ZkMetadataCache is requested to updateMetadata

controllerId¶

int controllerId()

Used when:

• KafkaApis is requested to handleStopReplicaRequest
• ReplicaManager is requested to maybeUpdateMetadataCache, becomeLeaderOrFollower
• ZkMetadataCache is requested to updateMetadata

Implementations¶

• LeaderAndIsrRequest
• StopReplicaRequest
• UpdateMetadataRequest

Creating Instance¶

AbstractControlRequest takes the following to be created:

• ApiKeys
• Version