K
- the key type.V
- the value type.public class RecordMessagingMessageListenerAdapter<K,V> extends MessagingMessageListenerAdapter<K,V> implements AcknowledgingConsumerAwareMessageListener<K,V>
MessageListener
adapter that invokes a configurable HandlerAdapter
; used when the factory is
configured for the listener to receive individual messages.
Wraps the incoming Kafka Message to Spring's Message
abstraction.
The original ConsumerRecord
and
the Acknowledgment
are provided as additional arguments so that these can
be injected as method arguments if necessary.
MessagingMessageListenerAdapter.ReplyExpressionRoot
ConsumerSeekAware.ConsumerSeekCallback
logger, NULL_MESSAGE
Constructor and Description |
---|
RecordMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method) |
RecordMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method,
KafkaListenerErrorHandler errorHandler) |
Modifier and Type | Method and Description |
---|---|
void |
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment acknowledgment,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Kafka
AcknowledgingConsumerAwareMessageListener entry point. |
createMessagingErrorMessage, determineInferredType, getMessageConverter, getReplyHeadersConfigurer, getType, handleResult, invokeHandler, isConsumerRecordList, isConsumerRecords, isConversionNeeded, isMessageList, isSplitIterables, onIdleContainer, onPartitionsAssigned, onPartitionsRevoked, registerSeekCallback, sendResponse, sendResponse, setBeanResolver, setFallbackType, setHandlerMethod, setMessageConverter, setReplyHeadersConfigurer, setReplyTemplate, setReplyTopic, setSplitIterables, toMessagingMessage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
onMessage
onMessage, onMessage
unregisterSeekCallback
public RecordMessagingMessageListenerAdapter(java.lang.Object bean, java.lang.reflect.Method method)
public RecordMessagingMessageListenerAdapter(java.lang.Object bean, java.lang.reflect.Method method, KafkaListenerErrorHandler errorHandler)
public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
AcknowledgingConsumerAwareMessageListener
entry point.
Delegate the message to the target listener method, with appropriate conversion of the message argument.
onMessage
in interface AcknowledgingConsumerAwareMessageListener<K,V>
onMessage
in interface GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
record
- the incoming Kafka ConsumerRecord
.acknowledgment
- the acknowledgment.consumer
- the consumer.