K - the key type.V - the value type.public class MessagingMessageListenerAdapter<K,V> extends AbstractAdaptableMessageListener<K,V>
MessageListener
adapter that invokes a configurable HandlerAdapter.
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.
logger| Constructor and Description |
|---|
MessagingMessageListenerAdapter() |
| Modifier and Type | Method and Description |
|---|---|
protected MessageConverter<K,V> |
getMessageConverter()
Return the
MessagingMessageConverter for this listener,
being able to convert Message. |
void |
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment acknowledgment)
Executes when a Kafka message is received.
|
void |
setHandlerMethod(HandlerAdapter handlerMethod)
Set the
HandlerAdapter to use to invoke the method
processing an incoming ConsumerRecord. |
void |
setMessageConverter(MessageConverter<K,V> messageConverter)
Set the MessageConverter.
|
protected org.springframework.messaging.Message<?> |
toMessagingMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment acknowledgment) |
extractMessage, handleListenerException, onMessagepublic void setHandlerMethod(HandlerAdapter handlerMethod)
HandlerAdapter to use to invoke the method
processing an incoming ConsumerRecord.handlerMethod - HandlerAdapter instance.public void setMessageConverter(MessageConverter<K,V> messageConverter)
messageConverter - the converter.protected final MessageConverter<K,V> getMessageConverter()
MessagingMessageConverter for this listener,
being able to convert Message.MessagingMessageConverter for this listener,
being able to convert Message.public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment acknowledgment)
AcknowledgingMessageListenerrecord - the Kafka message to be processedacknowledgment - a handle for acknowledging the message processingprotected org.springframework.messaging.Message<?> toMessagingMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment acknowledgment)