Package org.apache.kafka.clients.admin
Class RecordsToDelete
- java.lang.Object
-
- org.apache.kafka.clients.admin.RecordsToDelete
-
@Evolving public class RecordsToDelete extends Object
Describe records to delete in a call toAdmin.deleteRecords(Map)
The API of this class is evolving, seeAdmin
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(Object o)
int
hashCode()
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
-
-