View Source KafkaEx.Protocol.Kayrock.Fetch.Response protocol (kafka_ex v1.0.0-rc.1)

This protocol is used to parse Fetch responses.

Return Values

  • {:ok, Fetch.t()} on success with messages and metadata
  • {:error, Error.t()} on error with error details

All known versions (V0-V11) have explicit implementations. The Any fallback handles unknown future versions.

Summary

Types

t()

All the types that implement this protocol.

Types

@type t() :: term()

All the types that implement this protocol.

Functions

Link to this function

parse_response(response)

View Source
@spec parse_response(t()) ::
  {:ok, KafkaEx.Messages.Fetch.t()} | {:error, KafkaEx.Client.Error.t()}