Package org.apache.kafka.clients.admin

Class DeletedRecords

java.lang.Object

org.apache.kafka.clients.admin.DeletedRecords

@Evolving
public class DeletedRecords
extends java.lang.Object

Represents information about deleted records The API for this class is still evolving and we may break compatibility in minor releases, if necessary.

Constructor Summary

Constructors

Constructor	Description
DeletedRecords(long lowWatermark)	Create an instance of this class with the provided parameters.

Method Summary

Modifier and Type	Method	Description
long	lowWatermark()	Return the "low watermark" for the topic partition on which the deletion was executed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DeletedRecords

public DeletedRecords(long lowWatermark)

Create an instance of this class with the provided parameters.

Parameters:

lowWatermark - "low watermark" for the topic partition on which the deletion was executed

Method Detail

lowWatermark

public long lowWatermark()

Return the "low watermark" for the topic partition on which the deletion was executed