インターフェースの使用
org.springframework.kafka.retrytopic.DestinationTopicResolver
DestinationTopicResolver を使用するパッケージ
org.springframework.kafka.retrytopic 内の DestinationTopicResolver 使用
修飾子と型メソッド説明RetryTopicComponentFactory.destinationTopicResolver()DestinationTopicインスタンスを格納するために使用されるDestinationTopicResolverのインスタンスを作成し、特定のレコードの転送先を解決します。RetryTopicConfigurationSupport.destinationTopicResolver(ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider) 型 DestinationTopicResolver の引数を持つ型を返す org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明protected ConsumerSE<DestinationTopicResolver>RetryTopicConfigurationSupport.configureDestinationTopicResolver()このメソッドをオーバーライドして、DestinationTopicResolverを構成します。型 DestinationTopicResolver のパラメーターを持つ org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明RetryTopicComponentFactory.deadLetterPublishingRecovererFactory(DestinationTopicResolver destinationTopicResolver) レコードを特定のDestinationTopicに転送するためのDeadLetterPublishingRecovererの作成に使用されるDeadLetterPublishingRecovererFactoryを作成します。RetryTopicComponentFactory.destinationTopicProcessor(DestinationTopicResolver destinationTopicResolver) DestinationTopicインスタンスの処理に使用されるDestinationTopicProcessorを作成し、提供されたDestinationTopicResolverに格納します。RetryTopicConfigurationSupport.retryTopicConfigurer(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory) 対応するRetryTopicConfigurationを持つKafkaListenerEndpointインスタンスの再試行トピックを構成するためのグローバルRetryTopicConfigurerを返します。型 DestinationTopicResolver のパラメーターを持つ org.springframework.kafka.retrytopic のコンストラクター修飾子コンストラクター説明DeadLetterPublishingRecovererFactory(DestinationTopicResolver destinationTopicResolver) DefaultDestinationTopicProcessor(DestinationTopicResolver destinationTopicResolver)