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

    Methods inherited from class java.lang.Object

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

  • 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