RecordsToDelete (kafka 3.4.1 API)

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 Summary

Modifier and Type

Method

Description

long

beforeOffset()

The offset before which all records will be deleted

static RecordsToDelete

beforeOffset(long offset)

Delete all the records before the given offset

boolean

equals(Object o)

int

hashCode()

String

toString()

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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