Class RetryTopicConfigurationProvider

java.lang.Object
org.springframework.kafka.annotation.RetryTopicConfigurationProvider

public class RetryTopicConfigurationProvider extends Object
Attempts to provide an instance of RetryTopicConfiguration by either creating one from a RetryableTopic annotation, or from the bean container if no annotation is available. If beans are found in the container there's a check to determine whether or not the provided topics topics should be handled by any of such instances. If the annotation is provided, a DltHandler annotated method is looked up.
Since:
2.7
Author:
Tomaz Fernandes, Gary Russell
See Also:
  • Constructor Details

    • RetryTopicConfigurationProvider

      public RetryTopicConfigurationProvider(BeanFactory beanFactory)
      Construct an instance using the provided bean factory and default resolver and bean expression context.
      Parameters:
      beanFactory - the bean factory.
    • RetryTopicConfigurationProvider

      public RetryTopicConfigurationProvider(BeanFactory beanFactory, BeanExpressionResolver resolver, BeanExpressionContext expressionContext)
      Construct an instance using the provided parameters.
      Parameters:
      beanFactory - the bean factory.
      resolver - the bean expression resolver.
      expressionContext - the bean expression context.
  • Method Details