K
- the key type.V
- the value type.@FunctionalInterface
public interface BatchToRecordAdapter<K,V>
Modifier and Type | Interface and Description |
---|---|
static interface |
BatchToRecordAdapter.Callback<K,V>
A callback for each message.
|
Modifier and Type | Method and Description |
---|---|
void |
adapt(java.util.List<org.springframework.messaging.Message<?>> messages,
java.util.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 adapt(java.util.List<org.springframework.messaging.Message<?>> messages, java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> records, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, BatchToRecordAdapter.Callback<K,V> callback)
messages
- the messages.records
- the records.ack
- the acknowledgment.consumer
- the consumer.callback
- the callback.