K - the key type.V - the value type.public interface AcknowledgingMessageListener<K,V>
| Modifier and Type | Method and Description |
|---|---|
void |
onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record,
Acknowledgment acknowledgment)
Executes when a Kafka message is received.
|
void onMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> record, Acknowledgment acknowledgment)
record - the Kafka message to be processedacknowledgment - a handle for acknowledging the message processing