public interface ConsumerSeekAware
ConsumerSeekAware.ConsumerSeekCallback
which can be used to perform a
seek operation.Modifier and Type | Interface and Description |
---|---|
static interface |
ConsumerSeekAware.ConsumerSeekCallback
A callback that a listener can invoke to seek to a specific offset.
|
Modifier and Type | Method and Description |
---|---|
default void |
onIdleContainer(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> assignments,
ConsumerSeekAware.ConsumerSeekCallback callback)
If the container is configured to emit idle container events, this method is called
when the container idle event is emitted - allowing a seek operation.
|
default void |
onPartitionsAssigned(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> assignments,
ConsumerSeekAware.ConsumerSeekCallback callback)
When using group management, called when partition assignments change.
|
default void |
onPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
When using group management, called when partition assignments are revoked.
|
default void |
registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback)
Register the callback to use when seeking at some arbitrary time.
|
default void |
unregisterSeekCallback()
Called when the listener consumer terminates allowing implementations to clean up
state, such as thread locals.
|
default void registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback)
ConcurrentMessageListenerContainer
or the same listener instance in multiple
containers listeners should store the callback in a ThreadLocal
.callback
- the callback.default void onPartitionsAssigned(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
assignments
- the new assignments and their current offsets.callback
- the callback to perform an initial seek after assignment.default void onPartitionsRevoked(java.util.Collection<org.apache.kafka.common.TopicPartition> partitions)
registerSeekCallback(ConsumerSeekCallback)
on this thread.partitions
- the partitions that have been revoked.default void onIdleContainer(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
assignments
- the new assignments and their current offsets.callback
- the callback to perform a seek.default void unregisterSeekCallback()