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