クラスの使用
org.springframework.kafka.retrytopic.RetryTopicComponentFactory
RetryTopicComponentFactory を使用するパッケージ
org.springframework.kafka.retrytopic 内の RetryTopicComponentFactory 使用
修飾子と型メソッド説明protected RetryTopicComponentFactoryRetryTopicConfigurationSupport.createComponentFactory()このメソッドをオーバーライドして、RetryTopicComponentFactoryのサブクラスに異なるコンポーネント実装またはサブクラスを提供します。型 RetryTopicComponentFactory の型引数を持つ org.springframework.kafka.retrytopic のメソッドパラメーター修飾子と型メソッド説明RetryTopicConfigurationSupport.destinationTopicResolver(ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider) RetryTopicConfigurationSupport.kafkaConsumerBackoffManager(ApplicationContext applicationContext, ListenerContainerRegistry registry, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, RetryTopicSchedulerWrapper wrapper, TaskScheduler taskScheduler) パーティションのバックオフに使用されるKafkaConsumerBackoffManagerインスタンスを作成します。RetryTopicConfigurationSupport.retryTopicConfigurer(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory) 対応するRetryTopicConfigurationを持つKafkaListenerEndpointインスタンスの再試行トピックを構成するためのグローバルRetryTopicConfigurerを返します。