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