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

Method Summary
 void onMessage(KafkaMessage message, Acknowledgment acknowledgment)
          Executes when a Kafka message is received
 

Method Detail

onMessage

void onMessage(KafkaMessage message,
               Acknowledgment acknowledgment)
Executes when a Kafka message is received

Parameters:
message - the Kafka message to be processed
acknowledgment - a handle for acknowledging the message processing