THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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
}
|
...