Package org.apache.kafka.clients.admin
Class RecordsToDelete
- java.lang.Object
-
- org.apache.kafka.clients.admin.RecordsToDelete
-
@Evolving public class RecordsToDelete extends java.lang.Object
Describe records to delete in a call toAdmin.deleteRecords(Map)The API of this class is evolving, seeAdminfor details.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description longbeforeOffset()The offset before which all records will be deletedstatic RecordsToDeletebeforeOffset(long offset)Delete all the records before the givenoffsetbooleanequals(java.lang.Object o)inthashCode()java.lang.StringtoString()
-
-
-
Method Detail
-
beforeOffset
public static RecordsToDelete beforeOffset(long offset)
Delete all the records before the givenoffset- 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(java.lang.Object o)
- Overrides:
equalsin classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-