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.