Package org.springframework.kafka.retrytopic

Class EndpointCustomizerFactory

java.lang.Object

org.springframework.kafka.retrytopic.EndpointCustomizerFactory

public class EndpointCustomizerFactory
extends Object

Creates the EndpointCustomizer that will be used by the RetryTopicConfigurer to customize the main, retry and DLT endpoints.

Since:

2.7.2

Author:

Tomaz Fernandes, Gary Russell, Wang Zhiyang

See Also:

• RetryTopicConfigurer
• DestinationTopic.Properties
• RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Constructor Summary

Constructors

Constructor	Description
EndpointCustomizerFactory(DestinationTopic.Properties destinationProperties, EndpointHandlerMethod beanMethod, BeanFactory beanFactory, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory)

Method Summary

Modifier and Type	Method	Description
protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,?>>	addSuffixesAndMethod(DestinationTopic.Properties properties)	Create MethodKafkaListenerEndpoint's EndpointCustomizer and support MultiMethodKafkaListenerEndpoint.
protected EndpointCustomizer	addSuffixesAndMethod(DestinationTopic.Properties properties, Object bean, Method method)	Deprecated, for removal: This API element is subject to removal in a future version.
final EndpointCustomizer<MethodKafkaListenerEndpoint<?,?>>	createEndpointCustomizer()
protected Collection<EndpointCustomizer.TopicNamesHolder>	customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider, MethodKafkaListenerEndpoint<?,?> endpoint)

Methods inherited from class java.lang.Object

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

Constructor Details

EndpointCustomizerFactory

public EndpointCustomizerFactory(DestinationTopic.Properties destinationProperties,
 EndpointHandlerMethod beanMethod,
 BeanFactory beanFactory,
 RetryTopicNamesProviderFactory retryTopicNamesProviderFactory)

Method Details

createEndpointCustomizer

public final EndpointCustomizer<MethodKafkaListenerEndpoint<?,?>> createEndpointCustomizer()

addSuffixesAndMethod

@Deprecated(since="3.2",
            forRemoval=true)
protected EndpointCustomizer addSuffixesAndMethod(DestinationTopic.Properties properties,
 Object bean,
 Method method)

Deprecated, for removal: This API element is subject to removal in a future version.

Create MethodKafkaListenerEndpoint's EndpointCustomizer, but not support MultiMethodKafkaListenerEndpoint. Replace by addSuffixesAndMethod(DestinationTopic.Properties)

Parameters:

properties - the destination-topic's properties.

bean - the bean.

method - the method.

Returns:

the endpoint customizer.

addSuffixesAndMethod

protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,?>> addSuffixesAndMethod(DestinationTopic.Properties properties)

Create MethodKafkaListenerEndpoint's EndpointCustomizer and support MultiMethodKafkaListenerEndpoint.

Parameters:

properties - the destination-topic's properties.

Returns:

the endpoint customizer.

Since:

3.2

customizeAndRegisterTopics

protected Collection<EndpointCustomizer.TopicNamesHolder> customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider namesProvider,
 MethodKafkaListenerEndpoint<?,?> endpoint)