UpdateMetadataRequest

UpdateMetadataRequest is a controller request with UPDATE_METADATA API key and the following properties:

  • Version

  • Controller ID

  • Controller Epoch

  • Broker Epoch

  • PartitionStates by TopicPartition (Map<TopicPartition, PartitionState>)

  • Live leaders (brokers with leaders)

KafkaApis and UpdateMetadataRequest

When received, UpdateMetadataRequest is handled by handleUpdateMetadataRequest.

UpdateMetadataRequest.Builder Factory Object

UpdateMetadataRequest comes with a concrete AbstractRequest.Builder factory object that can build a UpdateMetadataRequest.

UpdateMetadataRequest build(short version)

UpdateMetadataRequest.Builder is used exclusively when AbstractControllerBrokerRequestBatch is requested to send UpdateMetadata requests out to all brokers.

results matching ""

    No results matching ""