Package org.apache.kafka.clients.admin
Class DeletedRecords
java.lang.Object
org.apache.kafka.clients.admin.DeletedRecords
@Evolving public class DeletedRecords extends 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
-
Constructor Details
-
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 Details
-
lowWatermark
public long lowWatermark()Return the "low watermark" for the topic partition on which the deletion was executed
-