K - the key type.V - the value type.public class BatchMessagingMessageListenerAdapter<K,V> extends MessagingMessageListenerAdapter<K,V> implements BatchAcknowledgingConsumerAwareMessageListener<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.
MessagingMessageListenerAdapter.ReplyExpressionRoot, MessagingMessageListenerAdapter.ResultHolderConsumerSeekAware.ConsumerSeekCallbacklogger| Constructor and Description |
|---|
BatchMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method) |
BatchMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method,
KafkaListenerErrorHandler errorHandler) |
| 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,
Acknowledgment acknowledgment,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Kafka
MessageListener entry point. |
void |
setBatchMessageConverter(BatchMessageConverter messageConverter)
Set the BatchMessageConverter.
|
protected org.springframework.messaging.Message<?> |
toMessagingMessage(java.util.List records,
Acknowledgment acknowledgment,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer) |
createMessagingErrorMessage, determineInferredType, getMessageConverter, getType, handleResult, invokeHandler, isConsumerRecordList, isMessageList, onIdleContainer, onPartitionsAssigned, registerSeekCallback, sendResponse, sendResponse, setBeanResolver, setFallbackType, setHandlerMethod, setMessageConverter, setReplyTemplate, setReplyTopic, toMessagingMessageclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonMessageonMessage, onMessagepublic BatchMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method)
public BatchMessagingMessageListenerAdapter(java.lang.Object bean,
java.lang.reflect.Method method,
KafkaListenerErrorHandler errorHandler)
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, Acknowledgment acknowledgment, org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
MessageListener entry point.
Delegate the message to the target listener method, with appropriate conversion of the message argument.
onMessage in interface BatchAcknowledgingConsumerAwareMessageListener<K,V>onMessage in interface GenericMessageListener<java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>>records - the incoming list of Kafka ConsumerRecord.acknowledgment - the acknowledgment.consumer - the consumer.protected org.springframework.messaging.Message<?> toMessagingMessage(java.util.List records,
Acknowledgment acknowledgment,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer)