Spring Integration Kafka Support

org.springframework.integration.kafka.listener
Interface MessageListener

All Known Implementing Classes:
AbstractDecodingMessageListener

public interface MessageListener

Listener for handling incoming Kafka messages

Author:
Marius Bogoevici

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

Method Detail

onMessage

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

Parameters:
message - the Kafka message to be processed

Spring Integration Kafka Support