Package org.apache.kafka.clients.admin

Class RecordsToDelete

java.lang.Object
org.apache.kafka.clients.admin.RecordsToDelete
public class RecordsToDeleteextends Object
Describe records to delete in a call to Admin.deleteRecords(Map)

  • 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