クラス RetryTopicComponentFactory
java.lang.ObjectSE
org.springframework.kafka.retrytopic.RetryTopicComponentFactory
RetryTopicConfigurationSupport
で使用されるコンポーネントインスタンスを提供します。いずれかのメソッドをオーバーライドして別の実装またはサブクラスを提供してから、RetryTopicConfigurationSupport.createComponentFactory()
メソッドをオーバーライドしてこのファクトリのサブクラスを返します。- 導入:
- 2.9
- 作成者:
- Tomaz Fernandes
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected ClockSE
トピックの再試行プロセスで時間関連のすべての操作に使用されるClock
SE インスタンスを作成します。deadLetterPublishingRecovererFactory
(DestinationTopicResolver destinationTopicResolver) レコードを特定のDestinationTopic
に転送するためのDeadLetterPublishingRecoverer
の作成に使用されるDeadLetterPublishingRecovererFactory
を作成します。destinationTopicProcessor
(DestinationTopicResolver destinationTopicResolver) DestinationTopic
インスタンスの処理に使用されるDestinationTopicProcessor
を作成し、提供されたDestinationTopicResolver
に格納します。DestinationTopic
インスタンスを格納するために使用されるDestinationTopicResolver
のインスタンスを作成し、特定のレコードの転送先を解決します。トピックの再試行プロセスですべての時間関連操作に使用されるClock
SE インスタンスを返します。kafkaBackOffManagerFactory
(ListenerContainerRegistry registry, ApplicationContext applicationContext) パーティションのバックオフに使用されるKafkaConsumerBackoffManager
インスタンスの作成に使用されるKafkaBackOffManagerFactory
を作成します。listenerContainerFactoryConfigurer
(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory, ClockSE clock) ListenerContainerFactoryResolver
によって解決されるKafkaListenerContainerFactory
の構成に使用されるListenerContainerFactoryConfigurer
を作成します。listenerContainerFactoryResolver
(BeanFactory beanFactory) 特定のトピックの適切なKafkaListenerContainerFactory
を解決するために使用されるListenerContainerFactoryResolver
を作成します。retryTopicConfigurer
(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, ListenerContainerFactoryResolver factoryResolver, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) 適切なRetryTopicConfiguration
を処理することにより、特定のKafkaListenerEndpoint
のノンブロッキングトピックベースの遅延再試行を構成するためのエントリポイントとして機能するRetryTopicConfigurer
を作成します。再試行トピックのKafkaListenerEndpoint
のプロパティ名を提供するために使用されるRetryTopicNamesProviderFactory
インスタンスを作成します。
コンストラクターの詳細
RetryTopicComponentFactory
public RetryTopicComponentFactory()
メソッドの詳細
retryTopicConfigurer
public RetryTopicConfigurer retryTopicConfigurer(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, ListenerContainerFactoryResolver factoryResolver, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) 適切なRetryTopicConfiguration
を処理することにより、特定のKafkaListenerEndpoint
のノンブロッキングトピックベースの遅延再試行を構成するためのエントリポイントとして機能するRetryTopicConfigurer
を作成します。- パラメーター:
destinationTopicProcessor
-DestinationTopic
インスタンスを処理し、DestinationTopicContainer
に登録するために使用されるDestinationTopicProcessor
。listenerContainerFactoryConfigurer
- ノンブロッキング遅延再試行機能用にKafkaListenerContainerFactory
インスタンスを構成するために使用されるListenerContainerFactoryConfigurer
。factoryResolver
- 特定のエンドポイントまたはその再試行トピックの適切なKafkaListenerContainerFactory
を解決するために使用されるListenerContainerFactoryResolver
。retryTopicNamesProviderFactory
- 再試行トピックのエンドポイントのプロパティ名を提供するために使用されるRetryTopicNamesProviderFactory
。- 戻り値:
- インスタンス。
destinationTopicProcessor
public DestinationTopicProcessor destinationTopicProcessor(DestinationTopicResolver destinationTopicResolver) DestinationTopic
インスタンスの処理に使用されるDestinationTopicProcessor
を作成し、提供されたDestinationTopicResolver
に格納します。- パラメーター:
destinationTopicResolver
-DestinationTopic
インスタンスを格納するために使用されるDestinationTopicResolver
インスタンス。- 戻り値:
- インスタンス。
destinationTopicResolver
DestinationTopic
インスタンスを格納するために使用されるDestinationTopicResolver
のインスタンスを作成し、特定のレコードの転送先を解決します。- 戻り値:
- インスタンス。
deadLetterPublishingRecovererFactory
public DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory(DestinationTopicResolver destinationTopicResolver) レコードを特定のDestinationTopic
に転送するためのDeadLetterPublishingRecoverer
の作成に使用されるDeadLetterPublishingRecovererFactory
を作成します。- パラメーター:
destinationTopicResolver
- 宛先を解決するためのDestinationTopicResolver
インスタンス。- 戻り値:
- インスタンス。
listenerContainerFactoryResolver
特定のトピックの適切なKafkaListenerContainerFactory
を解決するために使用されるListenerContainerFactoryResolver
を作成します。- パラメーター:
beanFactory
- 必要に応じてKafkaListenerContainerFactory
インスタンスを取得するために使用されるBeanFactory
。- 戻り値:
- インスタンス。
listenerContainerFactoryConfigurer
public ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory, ClockSE clock) ListenerContainerFactoryResolver
によって解決されるKafkaListenerContainerFactory
の構成に使用されるListenerContainerFactoryConfigurer
を作成します。- パラメーター:
kafkaConsumerBackoffManager
-KafkaBackoffAwareMessageListenerAdapter
で使用されるKafkaConsumerBackoffManager
。deadLetterPublishingRecovererFactory
- 使用するDeadLetterPublishingRecoverer
インスタンスを提供するファクトリ。clock
- リスナーアダプターで使用されるClock
SE インスタンス。- 戻り値:
- インスタンス。
retryTopicNamesProviderFactory
再試行トピックのKafkaListenerEndpoint
のプロパティ名を提供するために使用されるRetryTopicNamesProviderFactory
インスタンスを作成します。- 戻り値:
- インスタンス。
kafkaBackOffManagerFactory
public KafkaBackOffManagerFactory kafkaBackOffManagerFactory(@Nullable ListenerContainerRegistry registry, ApplicationContext applicationContext) パーティションのバックオフに使用されるKafkaConsumerBackoffManager
インスタンスの作成に使用されるKafkaBackOffManagerFactory
を作成します。- パラメーター:
registry
-MessageListenerContainer
のフェッチに使用されるListenerContainerRegistry
。applicationContext
- アプリケーションコンテキスト。- 戻り値:
- インスタンス。
internalRetryTopicClock
トピックの再試行プロセスですべての時間関連操作に使用されるClock
SE インスタンスを返します。- 戻り値:
- インスタンス。
createInternalRetryTopicClock
トピックの再試行プロセスで時間関連のすべての操作に使用されるClock
SE インスタンスを作成します。- 戻り値:
- インスタンス。