deleteRecords(Map<TopicPartition, DeletionTarget>DeleteRecordsTarget> partitionsAndOffsets)

public DeleteRecordsResult deleteRecords(Map<TopicPartition, DeletionTarget>DeleteRecordsTarget> partitionsAndOffsets)
public DeleteRecordsResult deleteRecords(Map<TopicPartition, DeletionTarget>DeleteRecordsTarget> partitionsAndOffsets, DeleteRecordsOptions options)

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