View Source Kayrock.Fetch.V5.Response (kayrock v0.2.0)
Kayrock-generated response struct for Kafka fetch v5 API
messages
The schema of this API is
[
throttle_time_ms: :int32,
responses: {:array,
[
topic: :string,
partition_responses: {:array,
[
partition_header: [
partition: :int32,
error_code: :int16,
high_watermark: :int64,
last_stable_offset: :int64,
log_start_offset: :int64,
aborted_transactions: {:array,
[producer_id: :int64, first_offset: :int64]}
],
record_set: :records
]}
]}
]Summary
Functions
Returns the Kafka API key for this API
Returns the API version (5) implemented by this module
Deserialize data for this version of this API
Returns the schema of this message
Types
@type t() :: %Kayrock.Fetch.V5.Response{ correlation_id: integer(), responses: [ %{ topic: nil | binary(), partition_responses: [ %{ partition_header: %{ partition: nil | integer(), error_code: nil | integer(), high_watermark: nil | integer(), last_stable_offset: nil | integer(), log_start_offset: nil | integer(), aborted_transactions: [ %{producer_id: nil | integer(), first_offset: nil | integer()} ] }, record_set: nil | Kayrock.MessageSet.t() | Kayrock.RecordBatch.t() } ] } ], throttle_time_ms: nil | integer() }
Response struct for the Kafka fetch API v5