クラスの使用
org.springframework.kafka.retrytopic.RetryTopicConfigurer
RetryTopicConfigurer を使用するパッケージ
org.springframework.kafka.retrytopic 内の RetryTopicConfigurer 使用
修飾子と型メソッド説明RetryTopicComponentFactory.retryTopicConfigurer(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, ListenerContainerFactoryResolver factoryResolver, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) 適切なRetryTopicConfigurationを処理することにより、特定のKafkaListenerEndpointのノンブロッキングトピックベースの遅延再試行を構成するためのエントリポイントとして機能するRetryTopicConfigurerを作成します。RetryTopicConfigurationSupport.retryTopicConfigurer(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory) 対応するRetryTopicConfigurationを持つKafkaListenerEndpointインスタンスの再試行トピックを構成するためのグローバルRetryTopicConfigurerを返します。型 RetryTopicConfigurer の引数を持つ型を返す org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明protected ConsumerSE<RetryTopicConfigurer>RetryTopicConfigurationSupport.configureRetryTopicConfigurer()RetryTopicConfigurerを構成する必要がある場合は、このメソッドをオーバーライドします。