T
- the delegate type.public abstract class AbstractDelegatingMessageListenerAdapter<T> extends java.lang.Object implements ConsumerSeekAware, DelegatingMessageListener<T>
ConsumerSeekAware.ConsumerSeekCallback
Modifier and Type | Field and Description |
---|---|
protected T |
delegate |
protected ListenerType |
delegateType |
protected org.apache.commons.logging.Log |
logger |
Constructor and Description |
---|
AbstractDelegatingMessageListenerAdapter(T delegate) |
Modifier and Type | Method and Description |
---|---|
T |
getDelegate()
Return the delegate.
|
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.
|
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.
|
void |
registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback)
Register the callback to use when seeking at some arbitrary time.
|
protected final org.apache.commons.logging.Log logger
protected final T delegate
protected final ListenerType delegateType
public AbstractDelegatingMessageListenerAdapter(T delegate)
public T getDelegate()
DelegatingMessageListener
getDelegate
in interface DelegatingMessageListener<T>
public void registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback)
ConsumerSeekAware
ConcurrentMessageListenerContainer
or the same listener instance in multiple
containers listeners should store the callback in a ThreadLocal
.registerSeekCallback
in interface ConsumerSeekAware
callback
- the callback.public void onPartitionsAssigned(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
ConsumerSeekAware
onPartitionsAssigned
in interface ConsumerSeekAware
assignments
- the new assignments and their current offsets.callback
- the callback to perform an initial seek after assignment.public void onIdleContainer(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
ConsumerSeekAware
onIdleContainer
in interface ConsumerSeekAware
assignments
- the new assignments and their current offsets.callback
- the callback to perform a seek.