org.springframework.integration.kafka.listener
Interface AcknowledgingMessageListener
- All Known Implementing Classes:
- AbstractDecodingAcknowledgingMessageListener
public interface AcknowledgingMessageListener
Listener for handling incoming Kafka messages, propagating an acknowledgment handle that recipients
can invoke when the message has been processed.
- Since:
- 1.0.1
- Author:
- Marius Bogoevici
onMessage
void onMessage(KafkaMessage message,
Acknowledgment acknowledgment)
- Executes when a Kafka message is received
- Parameters:
message - the Kafka message to be processedacknowledgment - a handle for acknowledging the message processing