Kayrock-generated request struct for Kafka metadata v9 API
messages
The schema of this API is
[
topics: {:compact_array,
[name: :compact_string, tagged_fields: :tagged_fields]},
allow_auto_topic_creation: :boolean,
include_cluster_authorized_operations: :boolean,
include_topic_authorized_operations: :boolean,
tagged_fields: :tagged_fields
]Summary
Functions
Returns the Kafka API key for this API
Returns the API version (9) implemented by this module
Returns a function that can be used to deserialize the wire response from the broker for this message type
Returns the schema of this message
Serialize a message to binary data for transfer to a Kafka broker
Types
@type t() :: %Kayrock.Metadata.V9.Request{ allow_auto_topic_creation: nil | integer(), client_id: nil | binary(), correlation_id: nil | integer(), include_cluster_authorized_operations: nil | integer(), include_topic_authorized_operations: nil | integer(), tagged_fields: [{non_neg_integer(), binary()}], topics: nil | [%{name: nil | binary(), tagged_fields: [{non_neg_integer(), binary()}]}] }
Request struct for the Kafka metadata API v9
Functions
@spec api_key() :: integer()
Returns the Kafka API key for this API
@spec api_vsn() :: integer()
Returns the API version (9) implemented by this module
@spec response_deserializer() :: (binary() -> {Kayrock.Metadata.V9.Response.t(), binary()})
Returns a function that can be used to deserialize the wire response from the broker for this message type
@spec schema() :: term()
Returns the schema of this message
See above.
Serialize a message to binary data for transfer to a Kafka broker