Uses of Interface
org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback
Packages that use ConsumerSeekAware.ConsumerSeekCallback
Package
Description
Package for kafka listeners
Provides classes for adapting listeners.
-
Uses of ConsumerSeekAware.ConsumerSeekCallback in org.springframework.kafka.listener
Methods in org.springframework.kafka.listener that return ConsumerSeekAware.ConsumerSeekCallbackModifier and TypeMethodDescriptionprotected ConsumerSeekAware.ConsumerSeekCallbackAbstractConsumerSeekAware.getSeekCallbackFor(org.apache.kafka.common.TopicPartition topicPartition) Return the callback for the specified topic/partition.Methods in org.springframework.kafka.listener that return types with arguments of type ConsumerSeekAware.ConsumerSeekCallbackModifier 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.Methods in org.springframework.kafka.listener with parameters of type ConsumerSeekAware.ConsumerSeekCallbackModifier and TypeMethodDescriptiondefault voidConsumerSeekAware.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.voidAbstractConsumerSeekAware.onPartitionsAssigned(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) default voidConsumerSeekAware.onPartitionsAssigned(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) When using group management, called when partition assignments change.voidAbstractConsumerSeekAware.registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback) default voidConsumerSeekAware.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
Methods in org.springframework.kafka.listener.adapter with parameters of type ConsumerSeekAware.ConsumerSeekCallbackModifier and TypeMethodDescriptionvoidAbstractDelegatingMessageListenerAdapter.onIdleContainer(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) voidMessagingMessageListenerAdapter.onIdleContainer(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) voidAbstractDelegatingMessageListenerAdapter.onPartitionsAssigned(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) voidMessagingMessageListenerAdapter.onPartitionsAssigned(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) voidAbstractDelegatingMessageListenerAdapter.registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback) voidMessagingMessageListenerAdapter.registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback)