Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Fetch Request (Version: 13) => replica_id max_wait_time min_bytes max_bytes isolation_level session_id session_epoch [topics] [forgotten_topics_data] rack_id
  replica_id => INT32
  max_wait_time => INT32
  min_bytes => INT32
  max_bytes => INT32
  isolation_level => INT8
  session_id => INT32
  session_epoch => INT32
  topics => topic_id* [partitions]
    topic_id* => UUID 
    partitions => partition current_leader_epoch fetch_offset last_fetched_epoch log_start_offset partition_max_bytes
      partition => INT32
      current_leader_epoch => INT32
      fetch_offset => INT64
             last_fetched_epoch => INT32
      log_start_offset => INT64
      partition_max_bytes => INT32
  forgotten_topics_data => topic_id* [partitions]
         topic_id* => UUID
    partitions => INT32
  rack_id => STRING

...

Fetch Response (Version: 13) => throttle_time_ms error_code session_id [responses]
  throttle_time_ms => INT32
  error_code => INT16
  session_id => INT32
  responses => topic_id* [partition_responses]
    topic_id* => UUID 
    partition_responses => partition_header record_set
      partition_header => partition partition error_code high_watermark last_stable_offset log_start_offset diverging_epoch current_leader [aborted_transactions] preferred_read_replica record_set
        partition => INT32
        error_code => INT16
        high_watermark => INT64
        last_stable_offset => INT64
        log_start_offset => INT64
                  diverging_epoch => epoch end_offset
          epoch => INT32
          end_offset => INT64
                  current_leader => leader_id leader_epoch
                      leader_id => INT32
                      leader_epoch => INT32
        aborted_transactions => producer_id first_offset
          producer_id => INT64
          first_offset => INT64
        preferred_read_replica => INT32
              record_set => RECORDS

ListOffsets

...