Versions Compared

Key

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

...

Code Block
{
  size: int32                     // the size of this request
  request_type_id: int16          // the type of the request, distinguish Ping/RestartFetcher requests
  consumer_id: string             // id string of the consumer
  num_retries: int16              // indicate this is the #th ping retry
}

...

Code Block
{
  size: int32                              // the size of this request
  request_type_id: int16                   // the type of the request, distinguish Ping/RestartFetcher requests
  consumer_id: string                      // id string of the consumer  num_partitions: int16                    // the number of partitions assigned to the consumer
  assigned_parts: [<partition_struct>]     // the detailed info of assigned partitions, along with the starting offset
}

partition_struct =>
{
  topic: string
  partition: string                        // note that this partition string already contains the broker id
  offset: int64
}

...