Versions Compared

Key

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

...

 

Code Block
titlePurgeRequest
PurgeRequest => topics timeout
  topics => [PurgeRequestTopic]
  timeout => int32
 
PurgeRequestTopic => topic partitions
  topic => str
  partitions => [PurgeRequestPartition]
 
PurgeRequestPartition => partition offset
  partition => int32
  offset => int64  // offset -1L will be translated into high_watermark of the partition when leader receives the request.

 

Create PurgeReponse

 

Code Block
titlePurgeReponse
PurgeReponse => topics timeout
  topics => [PurgeResponseTopic]
 
PurgeResponseTopic => topic partitions
  topic => str
  partitions => [PurgeResponsePartition]
 
PurgeResponsePartition => partition low_watermark error_code
  partition => int32
  low_watermark => int32
  error_code => int16

 

...