partition :: {partition :: integer, offset :: integer, max_bytes :: integer}

t :: %Cafex.Protocol.Fetch.Request{max_wait_time: integer, min_bytes: integer, replica_id: integer, topics: [topic]}

topic :: {topic :: String.t, partitions :: [partition]}