deleteRecords(Map<TopicPartition, DeleteRecordsTarget>RecordsToDelete> partitionsAndOffsetsrecordsToDelete)

public DeleteRecordsResult deleteRecords(Map<TopicPartition, DeleteRecordsTarget>RecordsToDelete> partitionsAndOffsetsrecordsToDelete)
public DeleteRecordsResult deleteRecords(Map<TopicPartition, DeleteRecordsTarget>RecordsToDelete> partitionsAndOffsetsrecordsToDelete, DeleteRecordsOptions options)

/**
 * Options for {@link AdminClient#deleteRecords(Map, DeleteRecordsOptions)}.
 */
public class DeleteRecordsOptions extends AbstractOptions<DeleteRecordsOptions> {

}
 
/**
 * Describe records as targetto delete in a call to delete{@link AdminClient#deleteRecords(Map)}
 */
public class DeleteRecordsTargetRecordsToDelete {
	private long offset;
	
	/** 
	 * Delete all the records before the given {@code offset}
	 *
	 * @param offset    the offset before which all records will be deleted
	 */
	public static DeleteRecordsTargetRecordsToDelete deleteBeforebeforeOffset(long offset) { ... }
}

/**
 * The result of the {@link AdminClient#deleteRecords(Map)} call.
 */ 
public class DeleteRecordsResult {
    // package access constructor
    Map<TopicPartition, KafkaFuture<Long>>KafkaFuture<DeleteRecords>> values() { ... }
    KafkaFuture<Long>KafkaFuture<DeleteRecords> all() { ... }
}
 
/**
 * Represents information about deleted records
 */
public class DeletedRecords {
	private final long lowWatermark;
 
	/**
 	 * Create an instance of this class with the provided parameters.
 	 *
	 * @param lowWatermark  "low watermark" for the topic partition on which the deletion was executed
	 */
	public DeletedRecords(long lowWatermark) {
    	this.lowWatermark = lowWatermark;
	}

	/**
	 * Return the "low watermark" for the topic partition on which the deletion was executed
	 */
	public long lowWatermark() {
    	return lowWatermark;
	}
}