public interface AcknowledgingMessageListener
| Modifier and Type | Method and Description |
|---|---|
void |
onMessage(KafkaMessage message,
Acknowledgment acknowledgment)
Executes when a Kafka message is received
|
void onMessage(KafkaMessage message, Acknowledgment acknowledgment)
message - the Kafka message to be processedacknowledgment - a handle for acknowledging the message processing