パッケージ org.springframework.kafka.retrytopic

クラス RetryTopicConfiguration

java.lang.ObjectSE
org.springframework.kafka.retrytopic.RetryTopicConfiguration
public class RetryTopicConfiguration extends ObjectSE
再試行可能なトピック用に提供された構成が含まれています。RetryTopicConfigurationBuilder を介して作成する必要があります。
導入:
2.7
作成者:
Tomaz Fernandes, Gary Russell, Wang Zhiyang

  • メソッドの詳細

    • hasConfigurationForTopics

      public boolean hasConfigurationForTopics(StringSE[] topics)

    • forKafkaTopicAutoCreation

      public org.springframework.kafka.retrytopic.RetryTopicConfiguration.TopicCreation forKafkaTopicAutoCreation()

    • forContainerFactoryResolver

      public org.springframework.kafka.retrytopic.ListenerContainerFactoryResolver.Configuration forContainerFactoryResolver()

    • getDltHandlerMethod

      public EndpointHandlerMethod getDltHandlerMethod()

    • getDestinationTopicProperties

      public ListSE<DestinationTopic.Properties> getDestinationTopicProperties()

    • getConcurrency

      @Nullable public IntegerSE getConcurrency()