Class AbstractDelegatingMessageListenerAdapter<T>
java.lang.Object
org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter<T>
- Type Parameters:
T
- the delegate type.
- All Implemented Interfaces:
ConsumerSeekAware
,DelegatingMessageListener<T>
- Direct Known Subclasses:
AbstractFilteringMessageListener
,AbstractRetryingMessageListenerAdapter
,KafkaBackoffAwareMessageListenerAdapter
public abstract class AbstractDelegatingMessageListenerAdapter<T>
extends Object
implements ConsumerSeekAware, DelegatingMessageListener<T>
Top level class for all listener adapters.
- Since:
- 1.1
- Author:
- Gary Russell
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.springframework.kafka.listener.ConsumerSeekAware
ConsumerSeekAware.ConsumerSeekCallback
-
Field Summary
Modifier and TypeFieldDescriptionprotected final T
protected final ListenerType
protected final LogAccessor
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionReturn the delegate.void
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
onPartitionsAssigned
(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) When using group management, called when partition assignments change.void
onPartitionsRevoked
(Collection<org.apache.kafka.common.TopicPartition> partitions) When using group management, called when partition assignments are revoked.void
Register the callback to use when seeking at some arbitrary time.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.kafka.listener.ConsumerSeekAware
onFirstPoll, unregisterSeekCallback
-
Field Details
-
logger
-
delegate
-
delegateType
-
-
Constructor Details
-
AbstractDelegatingMessageListenerAdapter
-
-
Method Details
-
getDelegate
Description copied from interface:DelegatingMessageListener
Return the delegate.- Specified by:
getDelegate
in interfaceDelegatingMessageListener<T>
- Returns:
- the delegate.
-
registerSeekCallback
Description copied from interface:ConsumerSeekAware
Register the callback to use when seeking at some arbitrary time. When used with aConcurrentMessageListenerContainer
or the same listener instance in multiple containers listeners should store the callback in aThreadLocal
or a map keyed by the thread.- Specified by:
registerSeekCallback
in interfaceConsumerSeekAware
- Parameters:
callback
- the callback.
-
onPartitionsAssigned
public void onPartitionsAssigned(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) Description copied from interface:ConsumerSeekAware
When using group management, called when partition assignments change.- Specified by:
onPartitionsAssigned
in interfaceConsumerSeekAware
- Parameters:
assignments
- the new assignments and their current offsets.callback
- the callback to perform an initial seek after assignment.
-
onPartitionsRevoked
Description copied from interface:ConsumerSeekAware
When using group management, called when partition assignments are revoked. Listeners should discard any callback saved fromConsumerSeekAware.registerSeekCallback(ConsumerSeekCallback)
on this thread.- Specified by:
onPartitionsRevoked
in interfaceConsumerSeekAware
- Parameters:
partitions
- the partitions that have been revoked.
-
onIdleContainer
public void onIdleContainer(Map<org.apache.kafka.common.TopicPartition, Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback) Description copied from interface:ConsumerSeekAware
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.- Specified by:
onIdleContainer
in interfaceConsumerSeekAware
- Parameters:
assignments
- the new assignments and their current offsets.callback
- the callback to perform a seek.
-