View Source KafkaEx.Protocol.Kayrock.OffsetCommit.ResponseHelpers (kafka_ex v1.0.0-rc.1)

Shared helper functions for parsing OffsetCommit responses across all versions (V0-V8).

All versions share the same response parsing logic — only the wire format semantics differ. Response only contains partition and error_code (no offset returned). V8 is a flexible version (KIP-482) with tagged_fields, handled transparently by Kayrock.

Summary

Types

error_tuple()

Functions

parse_response(map)

Parses an OffsetCommit response.

Types

Link to this type

error_tuple()

View Source 
@type error_tuple() :: {atom(), String.t(), non_neg_integer()}

Functions

Link to this function

parse_response(map)

View Source 
@spec parse_response(map()) :: {:ok, [KafkaEx.Messages.Offset.t()]} | {:error, any()}

Parses an OffsetCommit response.

All versions share the same response parsing logic.