Class EndpointCustomizerFactory
java.lang.Object
org.springframework.kafka.retrytopic.EndpointCustomizerFactory
Creates the
EndpointCustomizer that will be used by the RetryTopicConfigurer
to customize the main, retry and DLT endpoints.-
Method Summary
Modifier and TypeMethodDescriptionprotected EndpointCustomizeraddSuffixesAndMethod(DestinationTopic.Properties properties, Object bean, Method method) final EndpointCustomizerprotected Collection<EndpointCustomizer.TopicNamesHolder>customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider, MethodKafkaListenerEndpoint<?, ?> endpoint)
-
Method Details
-
createEndpointCustomizer
-
addSuffixesAndMethod
protected EndpointCustomizer addSuffixesAndMethod(DestinationTopic.Properties properties, Object bean, Method method) -
customizeAndRegisterTopics
protected Collection<EndpointCustomizer.TopicNamesHolder> customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider, MethodKafkaListenerEndpoint<?, ?> endpoint)
-