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 |
seekRelative(java.lang.String topic,
int partition,
long offset,
boolean toCurrent)
Perform a seek relative to the start, end, or current position.
|
default void |
seekToBeginning(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
Perform a seek to beginning operation.
|
void |
seekToBeginning(java.lang.String topic,
int partition)
Perform a seek to beginning operation.
|
default void |
seekToEnd(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
Perform a seek to end operation.
|
void |
seekToEnd(java.lang.String topic,
int partition)
Perform a seek to end operation.
|
void |
seekToTimestamp(java.util.Collection<org.apache.kafka.common.TopicPartition> topicPartitions,
long timestamp)
Perform a seek to the first offset greater than or equal to the time stamp.
|
void |
seekToTimestamp(java.lang.String topic,
int partition,
long timestamp)
Perform a seek to the first offset greater than or equal to the time stamp.
|
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.default void seekToBeginning(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
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 for each
TopicPartition
. The seek will occur after any pending offset commits.
The consumer must be currently assigned the specified partition(s).partitions
- the TopicPartition
s.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.default void seekToEnd(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
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 for each TopicPartition
. The queued
seek(s) will occur after any pending offset commits. The consumer must be
currently assigned the specified partition(s).partitions
- the TopicPartition
s.void seekRelative(java.lang.String topic, int partition, long offset, boolean toCurrent)
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. 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; positive values are relative to the start, negative
values are relative to the end, unless toCurrent is true.toCurrent
- true for the offset to be relative to the current position
rather than the beginning or end.void seekToTimestamp(java.lang.String topic, int partition, long timestamp)
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. The queued seek will occur after any pending offset
commits. The consumer must be currently assigned the specified partition. Use
seekToTimestamp(Collection, long)
when seeking multiple partitions
because the offset lookup is blocking.topic
- the topic.partition
- the partition.timestamp
- the time stamp.seekToTimestamp(Collection, long)
void seekToTimestamp(java.util.Collection<org.apache.kafka.common.TopicPartition> topicPartitions, long timestamp)
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. The queued seek will occur after any pending offset
commits. The consumer must be currently assigned the specified partition.topicPartitions
- the topic/partitions.timestamp
- the time stamp.