K
- the key type.V
- the value type.public class RecordMessagingMessageListenerAdapter<K,V> extends MessagingMessageListenerAdapter<K,V> implements MessageListener<K,V>, AcknowledgingMessageListener<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.
ConsumerSeekAware.ConsumerSeekCallback
logger
Constructor and Description |
---|
RecordMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method) |
Modifier and Type | Method and Description |
---|---|
void |
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
Kafka
MessageListener entry point. |
void |
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment acknowledgment)
Invoked with data from kafka.
|
determineInferredType, getMessageConverter, getType, invokeHandler, isConsumerRecordList, isMessageList, onIdleContainer, onPartitionsAssigned, registerSeekCallback, setFallbackType, setHandlerMethod, setMessageConverter, toMessagingMessage
public RecordMessagingMessageListenerAdapter(java.lang.Object bean, java.lang.reflect.Method method)
public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record)
MessageListener
entry point.
Delegate the message to the target listener method, with appropriate conversion of the message argument.
onMessage
in interface GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
record
- the incoming Kafka ConsumerRecord
.public void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment acknowledgment)
GenericAcknowledgingMessageListener
onMessage
in interface GenericAcknowledgingMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
record
- the data to be processed.acknowledgment
- the acknowledgment.