Uses of Class
org.springframework.kafka.retrytopic.DestinationTopic.Properties
-
Uses of DestinationTopic.Properties in org.springframework.kafka.retrytopic
Modifier and TypeFieldDescriptionprotected final List<DestinationTopic.Properties>
DestinationTopicProcessor.Context.properties
Modifier and TypeMethodDescriptionDestinationTopicPropertiesFactory.createProperties()
RetryTopicConfiguration.getDestinationTopicProperties()
Modifier and TypeMethodDescriptionprotected EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> EndpointCustomizerFactory.addSuffixesAndMethod
(DestinationTopic.Properties properties) Create MethodKafkaListenerEndpoint's EndpointCustomizer and support MultiMethodKafkaListenerEndpoint.protected EndpointCustomizer
EndpointCustomizerFactory.addSuffixesAndMethod
(DestinationTopic.Properties properties, Object bean, Method method) Deprecated, for removal: This API element is subject to removal in a future version.protected EndpointCustomizer<MethodKafkaListenerEndpoint<?,
?>> RetryTopicConfigurer.createEndpointCustomizer
(EndpointHandlerMethod endpointBeanMethod, DestinationTopic.Properties destinationTopicProperties) RetryTopicNamesProviderFactory.createRetryTopicNamesProvider
(DestinationTopic.Properties properties) SuffixingRetryTopicNamesProviderFactory.createRetryTopicNamesProvider
(DestinationTopic.Properties properties) protected EndpointHandlerMethod
RetryTopicConfigurer.getEndpointHandlerMethod
(MethodKafkaListenerEndpoint<?, ?> mainEndpoint, RetryTopicConfiguration configuration, DestinationTopic.Properties props) void
DefaultDestinationTopicProcessor.registerDestinationTopic
(String mainTopicName, String destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context) void
DestinationTopicProcessor.registerDestinationTopic
(String mainTopicName, String destinationTopicName, DestinationTopic.Properties destinationTopicProperties, DestinationTopicProcessor.Context context) Register the destination topic.Modifier and TypeMethodDescriptionvoid
DefaultDestinationTopicProcessor.processDestinationTopicProperties
(Consumer<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context) void
DestinationTopicProcessor.processDestinationTopicProperties
(Consumer<DestinationTopic.Properties> destinationPropertiesProcessor, DestinationTopicProcessor.Context context) Process the destination properties.ModifierConstructorDescriptionDestinationTopic
(String destinationName, DestinationTopic.Properties properties) EndpointCustomizerFactory
(DestinationTopic.Properties destinationProperties, EndpointHandlerMethod beanMethod, BeanFactory beanFactory, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) Properties
(DestinationTopic.Properties sourceProperties, String suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type) Create an instance with the provided properties with the DLT container starting automatically.ModifierConstructorDescriptionContext
(String listenerId, List<DestinationTopic.Properties> properties)