public static interface ConsumerSeekAware.ConsumerSeekCallback
| Modifier and Type | Method and Description |
|---|---|
void |
seek(java.lang.String topic,
int partition,
long offset)
Perform a seek operation.
|
void |
seekToBeginning(java.lang.String topic,
int partition)
Perform a seek to beginning operation.
|
void |
seekToEnd(java.lang.String topic,
int partition)
Perform a seek to end operation.
|
void seek(java.lang.String topic,
int partition,
long offset)
ConsumerSeekAware.onPartitionsAssigned(Map, ConsumerSeekCallback) or
from ConsumerSeekAware.onIdleContainer(Map, ConsumerSeekCallback)
perform the seek immediately on the consumer. When called from elsewhere,
queue the seek operation to the consumer. The queued seek will occur after any
pending offset commits. The consumer must be currently assigned the specified
partition.topic - the topic.partition - the partition.offset - the offset (absolute).void seekToBeginning(java.lang.String topic,
int partition)
ConsumerSeekAware.onPartitionsAssigned(Map, ConsumerSeekCallback) or
from ConsumerSeekAware.onIdleContainer(Map, ConsumerSeekCallback)
perform the seek immediately on the consumer. When called from elsewhere, queue
the seek operation to the consumer. The queued seek will occur after
any pending offset commits. The consumer must be currently assigned the
specified partition.topic - the topic.partition - the partition.void seekToEnd(java.lang.String topic,
int partition)
ConsumerSeekAware.onPartitionsAssigned(Map, ConsumerSeekCallback) or
from ConsumerSeekAware.onIdleContainer(Map, ConsumerSeekCallback)
perform the seek immediately on the consumer. When called from elsewhere, queue
the seek operation to the consumer. The queued seek will occur after any
pending offset commits. The consumer must be currently assigned the specified
partition.topic - the topic.partition - the partition.