Page History

/** Describe records as target to delete */
public class DeleteRecordsDeletionTarget {
	private Longlong offset;
	
	/**
	* Delete all the records before the given {@code offset}
	*/
	public static DeleteRecordsDeletionTarget deleteBefore(Longlong offset) { ... }
}
 
public class DeleteRecordsResult {
    // package access constructor
    Map<TopicPartition, KafkaFuture<Long>> values() { ... }
    KafkaFuture<Long> all() { ... }
}