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(java.lang.reflect.Method method) |
| Modifier and Type | Method and Description |
|---|---|
protected MessageConverter |
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 messageConverter)
Set the MessageConverter.
|
protected org.springframework.messaging.Message<?> |
toMessagingMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment acknowledgment) |
extractMessage, handleListenerException, onMessagepublic MessagingMessageListenerAdapter(java.lang.reflect.Method method)
public void setHandlerMethod(HandlerAdapter handlerMethod)
HandlerAdapter to use to invoke the method
processing an incoming ConsumerRecord.handlerMethod - HandlerAdapter instance.public void setMessageConverter(MessageConverter messageConverter)
messageConverter - the converter.protected final MessageConverter 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)