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 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