Interface BatchToRecordAdapter.Callback<K,V>
- Type Parameters:
K- the key type.V- the value type.
- Enclosing interface:
- BatchToRecordAdapter<K,
V>
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
A callback for each message.
-
Method Summary
Modifier and TypeMethodDescriptionvoidinvoke(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.
-
Method Details
-
invoke
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.- Parameters:
record- the record.ack- the acknowledgment.consumer- the consumer.message- the message.
-