K - the key type.V - the value type.public class RetryingAcknowledgingMessageListenerAdapter<K,V> extends AbstractRetryingMessageListenerAdapter<K,V,AcknowledgingMessageListener<K,V>> implements AcknowledgingMessageListener<K,V>
MessageListeners.ConsumerSeekAware.ConsumerSeekCallbackCONTEXT_ACKNOWLEDGMENT, CONTEXT_RECORDlogger| Constructor and Description |
|---|
RetryingAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<K,V> messageListener,
org.springframework.retry.support.RetryTemplate retryTemplate)
Construct an instance with the provided template and delegate.
|
RetryingAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<K,V> messageListener,
org.springframework.retry.support.RetryTemplate retryTemplate,
org.springframework.retry.RecoveryCallback<? extends java.lang.Object> recoveryCallback)
Construct an instance with the provided template, callback and delegate.
|
| Modifier and Type | Method and Description |
|---|---|
void |
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment acknowledgment)
Invoked with data from kafka.
|
getRecoveryCallback, getRetryTemplateonIdleContainer, onPartitionsAssigned, registerSeekCallbackpublic RetryingAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<K,V> messageListener, org.springframework.retry.support.RetryTemplate retryTemplate)
messageListener - the listener delegate.retryTemplate - the template.public RetryingAcknowledgingMessageListenerAdapter(AcknowledgingMessageListener<K,V> messageListener, org.springframework.retry.support.RetryTemplate retryTemplate, org.springframework.retry.RecoveryCallback<? extends java.lang.Object> recoveryCallback)
messageListener - the listener delegate.retryTemplate - the template.recoveryCallback - the recovery callback; if null, the exception will be
thrown to the container after retries are exhausted.public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment acknowledgment)
GenericAcknowledgingMessageListeneronMessage in interface GenericAcknowledgingMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>record - the data to be processed.acknowledgment - the acknowledgment.