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.