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: 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 response error code. (int16 | versions 0+)

• error_message: The response error 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:

• controller_id: The ID of the controller to register. (int32 | versions 0+)

• incarnation_id: The controller incarnation ID, which is unique to each process run. (uuid | versions 0+)

• zk_migration_ready: Set if the required configurations for ZK migration are present. (bool | versions 0+)

• listeners: The listeners of this controller ([]Listener | versions 0+)

  • name: The name of the endpoint. (string | versions 0+)

  • host: The hostname. (string | versions 0+)

  • port: The port. (uint16 | versions 0+)

  • security_protocol: The security protocol. (int16 | versions 0+)

• features: The features on this controller ([]Feature | versions 0+)

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

  • min_supported_version: The minimum supported feature level. (int16 | versions 0+)

  • max_supported_version: The maximum supported feature level. (int16 | versions 0+)