Returns the message api key number.

Receive a binary in the kafka wire format and deserialize it into a map.

Response content fields:

• throttle_time_ms: The duration in milliseconds for which the request was throttled due to a quota violation, or zero if the request did not violate any quota. (int32 | versions 0+)

• error_code: The top-level error code, or 0 if there was no error (int16 | versions 0+)

• error_message: The top-level error message, or null if there was no error. (string | versions 0+)

• topics: The ongoing reassignments for each topic. ([]OngoingTopicReassignment | versions 0+)

  • name: The topic name. (string | versions 0+)

  • partitions: The ongoing reassignments for each partition. ([]OngoingPartitionReassignment | versions 0+)

    • partition_index: The index of the partition. (int32 | versions 0+)

    • replicas: The current replica set. ([]int32 | versions 0+)

    • adding_replicas: The set of replicas we are currently adding. ([]int32 | versions 0+)

    • removing_replicas: The set of replicas we are currently removing. ([]int32 | versions 0+)

Returns the current max supported version of this message.

Returns the current min supported version of this message.

Receives a map and serialize it to kafka wire format of the given version.

Input content fields:

• timeout_ms: The time in ms to wait for the request to complete. (int32 | versions 0+)

• topics: The topics to list partition reassignments for, or null to list everything. ([]ListPartitionReassignmentsTopics | versions 0+)

  • name: The topic name (string | versions 0+)

  • partition_indexes: The partitions to list partition reassignments for. ([]int32 | versions 0+)