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+)

• results: The partition creation results for each topic. ([]CreatePartitionsTopicResult | versions 0+)

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

  • error_code: The result error, or zero if there was no error. (int16 | versions 0+)

  • error_message: The result message, or null if there was no error. (string | 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:

• topics: Each topic that we want to create new partitions inside. ([]CreatePartitionsTopic | versions 0+)

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

  • count: The new partition count. (int32 | versions 0+)

  • assignments: The new partition assignments. ([]CreatePartitionsAssignment | versions 0+)

    • broker_ids: The assigned broker IDs. ([]int32 | versions 0+)

• timeout_ms: The time in ms to wait for the partitions to be created. (int32 | versions 0+)

• validate_only: If true, then validate the request, but don't actually increase the number of partitions. (bool | versions 0+)