インターフェースの使用
org.springframework.kafka.listener.adapter.BatchToRecordAdapter.Callback
org.springframework.kafka.listener.adapter 内の BatchToRecordAdapter.Callback 使用
修飾子と型メソッド説明void
BatchToRecordAdapter.adapt
(ListSE<Message<?>> messages, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, BatchToRecordAdapter.Callback<K, V> callback) リストを調整し、各メッセージのコールバックを呼び出します。void
DefaultBatchToRecordAdapter.adapt
(ListSE<Message<?>> messages, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<K, V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?, ?> consumer, BatchToRecordAdapter.Callback<K, V> callback)