View Source KafkaEx.Protocol.Kayrock.Fetch.Request protocol (kafka_ex v1.0.0-rc.1)
This protocol is used to build Fetch requests.
Implementations must populate the request struct with:
replica_id- Should be -1 for consumersmax_wait_time- Maximum time to wait for messages in msmin_bytes- Minimum bytes to accumulate before returningtopics- List of topic/partition/offset data to fetchmax_bytes(V3+) - Maximum bytes to returnisolation_level(V4+) - 0 for READ_UNCOMMITTED, 1 for READ_COMMITTEDlog_start_offset(V5+) - Log start offset for partitionssession_id,epoch(V7+) - For incremental fetch sessionscurrent_leader_epoch(V9+) - Epoch of the current leader for partitionsrack_id(V11+) - Consumer rack ID for rack-aware fetch
All known versions (V0-V11) have explicit implementations.
The Any fallback handles unknown future versions.
Summary
Types
@type t() :: term()
All the types that implement this protocol.