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.
- Author:
- Marius Bogoevici
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)