Uses of Interface
org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
Package
Description
Package for kafka listeners
Provides classes for adapting listeners.
-
Uses of ConsumerSeekAware.ConsumerSeekCallback in org.springframework.kafka.listener
Modifier and TypeMethodDescriptionprotected ConsumerSeekAware.ConsumerSeekCallback
AbstractConsumerSeekAware.getSeekCallbackFor
(org.apache.kafka.common.TopicPartition topicPartition) Return the callback for the specified topic/partition.Modifier and TypeMethodDescriptionprotected Map<ConsumerSeekAware.ConsumerSeekCallback,
List<org.apache.kafka.common.TopicPartition>> AbstractConsumerSeekAware.getCallbacksAndTopics()
Return the currently registered callbacks and their associatedTopicPartition
(s).protected Map<org.apache.kafka.common.TopicPartition,
ConsumerSeekAware.ConsumerSeekCallback> AbstractConsumerSeekAware.getSeekCallbacks()
The map of callbacks for all currently assigned partitions.Modifier and TypeMethodDescriptiondefault void
ConsumerSeekAware.onIdleContainer
(Map<org.apache.kafka.common.TopicPartition, 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.void
AbstractConsumerSeekAware.onPartitionsAssigned
(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) default void
ConsumerSeekAware.onPartitionsAssigned
(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) When using group management, called when partition assignments change.void
AbstractConsumerSeekAware.registerSeekCallback
(ConsumerSeekAware.ConsumerSeekCallback callback) default void
ConsumerSeekAware.registerSeekCallback
(ConsumerSeekAware.ConsumerSeekCallback callback) Register the callback to use when seeking at some arbitrary time. -
Uses of ConsumerSeekAware.ConsumerSeekCallback in org.springframework.kafka.listener.adapter
Modifier and TypeMethodDescriptionvoid
AbstractDelegatingMessageListenerAdapter.onIdleContainer
(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) void
MessagingMessageListenerAdapter.onIdleContainer
(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) void
AbstractDelegatingMessageListenerAdapter.onPartitionsAssigned
(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) void
MessagingMessageListenerAdapter.onPartitionsAssigned
(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) void
AbstractDelegatingMessageListenerAdapter.registerSeekCallback
(ConsumerSeekAware.ConsumerSeekCallback callback) void
MessagingMessageListenerAdapter.registerSeekCallback
(ConsumerSeekAware.ConsumerSeekCallback callback)