Package org.springframework.kafka.config

Class MultiMethodKafkaListenerEndpoint<K,V>

java.lang.Object

org.springframework.kafka.config.AbstractKafkaListenerEndpoint<K,V>

org.springframework.kafka.config.MethodKafkaListenerEndpoint<K,V>

org.springframework.kafka.config.MultiMethodKafkaListenerEndpoint<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean, KafkaListenerEndpoint

public class MultiMethodKafkaListenerEndpoint<K,V>
extends MethodKafkaListenerEndpoint<K,V>

The MethodKafkaListenerEndpoint extension for several POJO methods based on the KafkaHandler.

Author:

Gary Russell

See Also:

• KafkaHandler
• DelegatingInvocableHandler

Constructor Summary

Constructors

Constructor	Description
MultiMethodKafkaListenerEndpoint(List<Method> methods, Method defaultMethod, Object bean)	Construct an instance for the provided methods, default method and bean.

Method Summary

Modifier and Type	Method	Description
protected HandlerAdapter	configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)	Create a HandlerAdapter for this listener adapter.
void	setValidator(Validator validator)	Set a payload validator.

Methods inherited from class org.springframework.kafka.config.MethodKafkaListenerEndpoint

createMessageListener, createMessageListenerInstance, getBean, getEndpointDescription, getMessageHandlerMethodFactory, getMethod, setBean, setErrorHandler, setMessageHandlerMethodFactory, setMessagingConverter, setMethod

Methods inherited from class org.springframework.kafka.config.AbstractKafkaListenerEndpoint

afterPropertiesSet, getAutoStartup, getBatchListener, getBatchToRecordAdapter, getBeanExpressionContext, getBeanFactory, getBeanResolver, getClientIdPrefix, getConcurrency, getConsumerProperties, getContainerPostProcessor, getGroup, getGroupId, getId, getListenerInfo, getMainListenerId, getRecordFilterStrategy, getReplyTemplate, getResolver, getTopicPartitionsToAssign, getTopicPattern, getTopics, isAckDiscarded, isBatchListener, isSplitIterables, setAckDiscarded, setAutoStartup, setBatchListener, setBatchToRecordAdapter, setBeanFactory, setClientIdPrefix, setConcurrency, setConsumerProperties, setContainerPostProcessor, setCorrelationHeaderName, setGroup, setGroupId, setId, setListenerInfo, setMainListenerId, setRecordFilterStrategy, setReplyHeadersConfigurer, setReplyTemplate, setSplitIterables, setTopicPartitions, setTopicPattern, setTopics, setupListenerContainer, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

MultiMethodKafkaListenerEndpoint

public MultiMethodKafkaListenerEndpoint(List<Method> methods,
 @Nullable
 Method defaultMethod,
 Object bean)

Construct an instance for the provided methods, default method and bean.

Parameters:

methods - the methods.

defaultMethod - the default method.

bean - the bean.

Since:

2.1.3

Method Details

setValidator

public void setValidator(Validator validator)

Set a payload validator.

Parameters:

validator - the validator.

Since:

2.5.11

configureListenerAdapter

protected HandlerAdapter configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)

Description copied from class: MethodKafkaListenerEndpoint

Create a HandlerAdapter for this listener adapter.

Overrides:

configureListenerAdapter in class MethodKafkaListenerEndpoint<K,V>

Parameters:

messageListener - the listener adapter.

Returns:

the handler adapter.