Package org.springframework.kafka.listener

Interface MessageListener<K,V>

Type Parameters:
K - the key type.
V - the value type.
All Superinterfaces:
GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
All Known Subinterfaces:
AcknowledgingConsumerAwareMessageListener<K,V>, AcknowledgingMessageListener<K,V>, ConsumerAwareMessageListener<K,V>
All Known Implementing Classes:
ConvertingMessageListener, FilteringMessageListenerAdapter, KafkaBackoffAwareMessageListenerAdapter, RecordMessagingMessageListenerAdapter
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface MessageListener<K,V> extends GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>
Listener for handling individual incoming Kafka messages.
Author:
Marius Bogoevici, Gary Russell