Kayrock-generated request struct for Kafka offset_commit v8 API
messages
The schema of this API is
[
group_id: :compact_string,
generation_id: :int32,
member_id: :compact_string,
group_instance_id: :compact_nullable_string,
topics: {:compact_array,
[
name: :compact_string,
partitions: {:compact_array,
[
partition_index: :int32,
committed_offset: :int64,
committed_leader_epoch: :int32,
committed_metadata: :compact_nullable_string,
tagged_fields: :tagged_fields
]},
tagged_fields: :tagged_fields
]},
tagged_fields: :tagged_fields
]
Summary
Functions
Returns the Kafka API key for this API
Returns the API version (8) 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.OffsetCommit.V8.Request{ client_id: nil | binary(), correlation_id: nil | integer(), generation_id: nil | integer(), group_id: nil | binary(), group_instance_id: nil | binary(), member_id: nil | binary(), tagged_fields: [{non_neg_integer(), binary()}], topics: nil | [ %{ name: nil | binary(), partitions: nil | [ %{ partition_index: nil | integer(), committed_offset: nil | integer(), committed_leader_epoch: nil | integer(), committed_metadata: nil | binary(), tagged_fields: [{non_neg_integer(), binary()}] } ], tagged_fields: [{non_neg_integer(), binary()}] } ] }
Request struct for the Kafka offset_commit API v8
Functions
@spec api_key() :: integer()
Returns the Kafka API key for this API
@spec api_vsn() :: integer()
Returns the API version (8) implemented by this module
@spec response_deserializer() :: (binary() -> {Kayrock.OffsetCommit.V8.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