Uses of Class
org.springframework.kafka.config.MethodKafkaListenerEndpoint
Packages that use MethodKafkaListenerEndpoint
Package
Description
Package for kafka annotations
Package for kafka configuration
Package for retryable topic handling.
-
Uses of MethodKafkaListenerEndpoint in org.springframework.kafka.annotation
Methods in org.springframework.kafka.annotation with parameters of type MethodKafkaListenerEndpointModifier and TypeMethodDescriptionprotected void
KafkaListenerAnnotationBeanPostProcessor.processListener
(MethodKafkaListenerEndpoint<?, ?> endpoint, KafkaListener kafkaListener, Object bean, String beanName, String[] topics, TopicPartitionOffset[] tps) -
Uses of MethodKafkaListenerEndpoint in org.springframework.kafka.config
Subclasses of MethodKafkaListenerEndpoint in org.springframework.kafka.configModifier and TypeClassDescriptionclass
TheMethodKafkaListenerEndpoint
extension for several POJO methods based on theKafkaHandler
. -
Uses of MethodKafkaListenerEndpoint in org.springframework.kafka.retrytopic
Classes in org.springframework.kafka.retrytopic with type parameters of type MethodKafkaListenerEndpointModifier and TypeInterfaceDescriptioninterface
EndpointCustomizer<T extends MethodKafkaListenerEndpoint<?,
?>> Customizes main, retry and DLT endpoints in the Retry Topic functionality and returns the resulting topic names.Methods in org.springframework.kafka.retrytopic that return types with arguments of type MethodKafkaListenerEndpointModifier and TypeMethodDescriptionprotected EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> EndpointCustomizerFactory.addSuffixesAndMethod
(DestinationTopic.Properties properties) Create MethodKafkaListenerEndpoint's EndpointCustomizer and support MultiMethodKafkaListenerEndpoint.final EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> EndpointCustomizerFactory.createEndpointCustomizer()
protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> RetryTopicConfigurer.createEndpointCustomizer
(EndpointHandlerMethod endpointBeanMethod, DestinationTopic.Properties destinationTopicProperties) Methods in org.springframework.kafka.retrytopic with parameters of type MethodKafkaListenerEndpointModifier and TypeMethodDescriptionprotected Collection<EndpointCustomizer.TopicNamesHolder>
EndpointCustomizerFactory.customizeAndRegisterTopics
(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider, MethodKafkaListenerEndpoint<?, ?> endpoint) protected EndpointHandlerMethod
RetryTopicConfigurer.getEndpointHandlerMethod
(MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, DestinationTopic.Properties props) default void
RetryTopicConfigurer.EndpointProcessor.process
(MethodKafkaListenerEndpoint<?, ?> listenerEndpoint) void
RetryTopicConfigurer.processMainAndRetryListeners
(RetryTopicConfigurer.EndpointProcessor endpointProcessor, MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, KafkaListenerEndpointRegistrar registrar, KafkaListenerContainerFactory<?> factory, String defaultContainerFactoryBeanName) Entrypoint for creating and configuring the retry and dlt endpoints, as well as the container factory that will create the corresponding listenerContainer.