クラスの使用
org.springframework.kafka.retrytopic.ListenerContainerFactoryResolver
org.springframework.kafka.retrytopic 内の ListenerContainerFactoryResolver 使用
修飾子と型メソッド説明RetryTopicComponentFactory.listenerContainerFactoryResolver
(BeanFactory beanFactory) 特定のトピックの適切なKafkaListenerContainerFactory
を解決するために使用されるListenerContainerFactoryResolver
を作成します。修飾子と型メソッド説明RetryTopicComponentFactory.retryTopicConfigurer
(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, ListenerContainerFactoryResolver factoryResolver, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) 適切なRetryTopicConfiguration
を処理することにより、特定のKafkaListenerEndpoint
のノンブロッキングトピックベースの遅延再試行を構成するためのエントリポイントとして機能するRetryTopicConfigurer
を作成します。修飾子コンストラクター説明RetryTopicConfigurer
(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryResolver containerFactoryResolver, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory) 提供されたプロパティでインスタンスを作成します。