Class RecordsToDelete

java.lang.Object
org.apache.kafka.clients.admin.RecordsToDelete

@Evolving
public class RecordsToDelete
extends Object
Describe records to delete in a call to Admin.deleteRecords(Map) The API of this class is evolving, see Admin for details.
  • Method Details

    • beforeOffset

      public static RecordsToDelete beforeOffset​(long offset)
      Delete all the records before the given offset
      Parameters:
      offset - the offset before which all records will be deleted
    • beforeOffset

      public long beforeOffset()
      The offset before which all records will be deleted
    • equals

      public boolean equals​(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object
    • toString

      public String toString()
      Overrides:
      toString in class Object