Spring Integration Kafka Support

org.springframework.integration.kafka.core
Class FetchRequest

java.lang.Object
  extended by 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

Constructor Summary
FetchRequest(Partition Partition, long offset, int maxSizeInBytes)
           
 
Method Summary
 int getMaxSizeInBytes()
           
 long getOffset()
           
 Partition getPartition()
           
 void setMaxSizeInBytes(int maxSizeInBytes)
           
 void setOffset(long offset)
           
 void setPartition(Partition partition)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

FetchRequest

public FetchRequest(Partition Partition,
                    long offset,
                    int maxSizeInBytes)
Method Detail

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)

Spring Integration Kafka Support