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