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()
DelegatingMessageListenergetDelegate in interface DelegatingMessageListener<T>public void registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback)
ConsumerSeekAwareConcurrentMessageListenerContainer or the same listener instance in multiple
containers listeners should store the callback in a ThreadLocal.registerSeekCallback in interface ConsumerSeekAwarecallback - the callback.public void onPartitionsAssigned(java.util.Map<org.apache.kafka.common.TopicPartition,java.lang.Long> assignments,
ConsumerSeekAware.ConsumerSeekCallback callback)
ConsumerSeekAwareonPartitionsAssigned in interface ConsumerSeekAwareassignments - 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)
ConsumerSeekAwareonIdleContainer in interface ConsumerSeekAwareassignments - the new assignments and their current offsets.callback - the callback to perform a seek.