org.springframework.integration.kafka.support
Class MessageLeftOverTracker<K,V>
java.lang.Object
org.springframework.integration.kafka.support.MessageLeftOverTracker<K,V>
public class MessageLeftOverTracker<K,V>
- extends java.lang.Object
- Since:
- 0.5
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageLeftOverTracker
public MessageLeftOverTracker()
addMessageAndMetadata
public void addMessageAndMetadata(kafka.message.MessageAndMetadata<K,V> messageAndMetadata)
getMessageLeftOverFromPreviousPoll
public java.util.List<kafka.message.MessageAndMetadata<K,V>> getMessageLeftOverFromPreviousPoll()
clearMessagesLeftOver
public void clearMessagesLeftOver()
getCurrentCount
public int getCurrentCount()