K
- the key type.V
- the value type.@FunctionalInterface public interface AcknowledgingMessageListener<K,V> extends MessageListener<K,V>
Modifier and Type | Method and Description |
---|---|
default void |
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data)
Invoked with data from kafka.
|
void |
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data,
Acknowledgment acknowledgment)
Invoked with data from kafka.
|
onMessage, onMessage
default void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data)
onMessage
in interface GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
data
- the data to be processed.void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> data, Acknowledgment acknowledgment)
onMessage
in interface GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
data
- the data to be processed.acknowledgment
- the acknowledgment.