Uses of Interface
org.springframework.kafka.listener.adapter.BatchToRecordAdapter.Callback
Package
Description
Provides classes for adapting listeners.
-
Uses of BatchToRecordAdapter.Callback in org.springframework.kafka.listener.adapter
Modifier and TypeMethodDescriptionvoid
BatchToRecordAdapter.adapt
(List<Message<?>> messages, List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, BatchToRecordAdapter.Callback<K, V> callback) Adapt the list and invoke the callback for each message.void
DefaultBatchToRecordAdapter.adapt
(List<Message<?>> messages, List<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, BatchToRecordAdapter.Callback<K, V> callback)