THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
deleteRecords(Map<TopicPartition, DeleteRecordsTarget>RecordsToDelete> partitionsAndOffsets) |
Proposed Changes
...
Code Block | ||
---|---|---|
| ||
public DeleteRecordsResult deleteRecords(Map<TopicPartition, DeleteRecordsTarget>RecordsToDelete> partitionsAndOffsets) public DeleteRecordsResult deleteRecords(Map<TopicPartition, DeleteRecordsTarget>RecordsToDelete> partitionsAndOffsets, DeleteRecordsOptions options) |
...
TopicPartition
comes from org.apache.kafka.common package
DeleteRecordsTarget
RecordsToDelete
and DeleteRecordsResult
are defined as follow.
Code Block | ||
---|---|---|
| ||
/** Describe records as target to delete */ public class DeleteRecordsTargetRecordsToDelete { private long offset; /** * Delete all the records before the given {@code offset} */ public static DeleteRecordsTargetRecordsToDelete deleteBeforebeforeOffset(long offset) { ... } } public class DeleteRecordsResult { // package access constructor Map<TopicPartition, KafkaFuture<Long>> values() { ... } KafkaFuture<Long> all() { ... } } |
...