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:

FilteringMessageListenerAdapter, RecordMessagingMessageListenerAdapter, RetryingMessageListenerAdapter

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

Method Summary

Methods inherited from interface org.springframework.kafka.listener.GenericMessageListener

onMessage, onMessage, onMessage, onMessage