org.springframework.integration.kafka.core
Class FetchRequest
java.lang.Object
org.springframework.integration.kafka.core.FetchRequest
public class FetchRequest
- extends java.lang.Object
Encapsulates a request for fetching messages from the server.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FetchRequest
public FetchRequest(Partition Partition,
long offset,
int maxSizeInBytes)
getPartition
public Partition getPartition()
setPartition
public void setPartition(Partition partition)
getOffset
public long getOffset()
setOffset
public void setOffset(long offset)
getMaxSizeInBytes
public int getMaxSizeInBytes()
setMaxSizeInBytes
public void setMaxSizeInBytes(int maxSizeInBytes)