@spec api_key(atom()) :: non_neg_integer()

Returns the integer API key for a given API name atom (e.g. :metadata → 3).

@spec atom_to_error_code!(atom()) :: integer()

Converts an error atom to its integer Kafka error code.

Builds kayrock request based on type, api version and opts

@spec error_code_to_atom(integer()) :: atom()

Converts an integer Kafka error code to its atom representation.

@spec max_supported_version(atom()) :: non_neg_integer()

Returns the maximum protocol version that Kayrock supports for the given API.

Parses response based on request type and response

@spec request_info(struct()) :: {atom(), non_neg_integer()}

Extracts operation name and API version from a Kayrock request struct.

Returns {operation, api_version} tuple where:

• operation is an atom like :metadata, :produce, :fetch, etc.
• api_version is an integer like 0, 1, 2, etc.

@spec response_deserializer(struct()) :: (binary() -> {struct(), binary()})

Returns the response deserializer function for a given request struct.

@spec serialize_request(struct()) :: iodata()

Serializes a Kayrock request struct to wire-format iodata.