Package org.apache.kafka.clients.admin

Class DeletedRecords

java.lang.Object
org.apache.kafka.clients.admin.DeletedRecords
public class DeletedRecords extends Object
Represents information about deleted records

  • 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