K - the key type.V - the value type.@FunctionalInterface
public static interface BatchToRecordAdapter.Callback<K,V>
| Modifier and Type | Method and Description |
|---|---|
void |
invoke(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment ack,
org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
org.springframework.messaging.Message<?> message)
Handle each message.
|
void invoke(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment ack, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, org.springframework.messaging.Message<?> message)
record - the record.ack - the acknowledgment.consumer - the consumer.message - the message.