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:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.InitializingBean,KafkaListenerEndpoint
The
MethodKafkaListenerEndpoint extension for several POJO methods
based on the KafkaHandler.- See Also:
-
Constructor Summary
ConstructorsConstructorDescriptionMultiMethodKafkaListenerEndpoint(List<Method> methods, Method defaultMethod, Object bean) Construct an instance for the provided methods, default method and bean. -
Method Summary
Modifier and TypeMethodDescriptionprotected HandlerAdapterconfigureListenerAdapter(MessagingMessageListenerAdapter<K, V> messageListener) Create aHandlerAdapterfor this listener adapter.voidsetValidator(org.springframework.validation.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, setMethodMethods inherited from class org.springframework.kafka.config.AbstractKafkaListenerEndpoint
afterPropertiesSet, getAutoStartup, getBatchListener, getBatchToRecordAdapter, getBeanExpressionContext, getBeanFactory, getBeanResolver, getClientIdPrefix, getConcurrency, getConsumerProperties, getGroup, getGroupId, getId, getListenerInfo, getMainListenerId, getRecordFilterStrategy, getReplyTemplate, getResolver, getTopicPartitionsToAssign, getTopicPattern, getTopics, isAckDiscarded, isBatchListener, isSplitIterables, setAckDiscarded, setAutoStartup, setBatchListener, setBatchToRecordAdapter, setBeanFactory, setClientIdPrefix, setConcurrency, setConsumerProperties, setCorrelationHeaderName, setGroup, setGroupId, setId, setListenerInfo, setMainListenerId, setRecordFilterStrategy, setReplyHeadersConfigurer, setReplyTemplate, setSplitIterables, setTopicPartitions, setTopicPattern, setTopics, setupListenerContainer, toString
-
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(org.springframework.validation.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:MethodKafkaListenerEndpointCreate aHandlerAdapterfor this listener adapter.- Overrides:
configureListenerAdapterin classMethodKafkaListenerEndpoint<K,V> - Parameters:
messageListener- the listener adapter.- Returns:
- the handler adapter.
-