K - the key type.V - the value type.public class BatchMessagingMessageListenerAdapter<K,V> extends MessagingMessageListenerAdapter<K,V> implements BatchMessageListener<K,V>, BatchAcknowledgingMessageListener<K,V>
MessageListener
adapter that invokes a configurable HandlerAdapter; used when the factory is
configured for the listener to receive batches of messages.
Wraps the incoming Kafka Message to Spring's Message abstraction.
The original List<ConsumerRecord> and
the Acknowledgment are provided as additional arguments so that these can
be injected as method arguments if necessary.
ConsumerSeekAware.ConsumerSeekCallbacklogger| Constructor and Description |
|---|
BatchMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method) |
| Modifier and Type | Method and Description |
|---|---|
protected BatchMessageConverter |
getBatchMessageConverter()
Return the
BatchMessagingMessageConverter for this listener,
being able to convert Message. |
void |
onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records)
Kafka
MessageListener entry point. |
void |
onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records,
Acknowledgment acknowledgment)
Invoked with data from kafka.
|
void |
setBatchMessageConverter(BatchMessageConverter messageConverter)
Set the BatchMessageConverter.
|
protected org.springframework.messaging.Message<?> |
toMessagingMessage(java.util.List records,
Acknowledgment acknowledgment) |
determineInferredType, getMessageConverter, getType, invokeHandler, isConsumerRecordList, isMessageList, onIdleContainer, onPartitionsAssigned, registerSeekCallback, setFallbackType, setHandlerMethod, setMessageConverter, toMessagingMessagepublic BatchMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method)
public void setBatchMessageConverter(BatchMessageConverter messageConverter)
messageConverter - the converter.protected final BatchMessageConverter getBatchMessageConverter()
BatchMessagingMessageConverter for this listener,
being able to convert Message.BatchMessagingMessageConverter for this listener,
being able to convert Message.public void onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records)
MessageListener entry point.
Delegate the message to the target listener method, with appropriate conversion of the message argument.
onMessage in interface GenericMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>records - the incoming Kafka ConsumerRecords.public void onMessage(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, Acknowledgment acknowledgment)
GenericAcknowledgingMessageListeneronMessage in interface GenericAcknowledgingMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>records - the data to be processed.acknowledgment - the acknowledgment.protected org.springframework.messaging.Message<?> toMessagingMessage(java.util.List records,
Acknowledgment acknowledgment)