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 toAdminClient.deleteRecords(Map)
The API of this class is evolving, seeAdminClient
for details.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description long
beforeOffset()
The offset before which all records will be deletedstatic RecordsToDelete
beforeOffset(long offset)
Delete all the records before the givenoffset
boolean
equals(java.lang.Object o)
int
hashCode()
java.lang.String
toString()
-
-
-
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:
equals
in classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-