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