View Source KafkaEx.Protocol.Kayrock.ListOffsets.Request protocol (kafka_ex v1.0.0-rc.1)

This protocol is used to build Lists Offsets request.

Implementations must populate the request struct with:

  • replica_id - Should be -1 for consumers
  • topics - List of topic/partition/timestamp data
  • isolation_level (V2+) - 0 for READ_UNCOMMITTED, 1 for READ_COMMITTED
  • current_leader_epoch (V4+ in Kayrock schema) - Epoch for fencing (-1 = unknown)

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

Summary

Types

t()

All the types that implement this protocol.

Functions

build_request(request, opts)

Types

Link to this type

t()

View Source 
@type t() :: term()

All the types that implement this protocol.

Functions

Link to this function

build_request(request, opts)

View Source 
@spec build_request(t(), Keyword.t()) :: t()