クラスの使用
org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.CustomizersConfigurer
org.springframework.kafka.retrytopic 内の RetryTopicConfigurationSupport.CustomizersConfigurer 使用
修飾子と型メソッド説明RetryTopicConfigurationSupport.CustomizersConfigurer.customizeDeadLetterPublishingRecoverer(ConsumerSE<DeadLetterPublishingRecoverer> dlprCustomizer) レコードを再試行トピックおよび DLT に転送するために使用されるDeadLetterPublishingRecovererをカスタマイズします。RetryTopicConfigurationSupport.CustomizersConfigurer.customizeErrorHandler(ConsumerSE<DefaultErrorHandler> errorHandlerCustomizer) 機能に使用されるCommonErrorHandlerインスタンスをカスタマイズします。RetryTopicConfigurationSupport.CustomizersConfigurer.customizeListenerContainer(ConsumerSE<ConcurrentMessageListenerContainer<?, ?>> listenerContainerCustomizer) 再試行および DLT コンシューマー用に作成されたConcurrentMessageListenerContainerインスタンスをカスタマイズします。型 RetryTopicConfigurationSupport.CustomizersConfigurer のパラメーターを持つ org.springframework.kafka.retrytopic のメソッド修飾子と型メソッド説明protected voidRetryTopicConfigurationSupport.configureCustomizers(RetryTopicConfigurationSupport.CustomizersConfigurer customizersConfigurer) このメソッドをオーバーライドして、MessageListenerContainer、DeadLetterPublishingRecoverer、DefaultErrorHandlerなどのノンブロッキング再試行の構成によって作成されたコンポーネントのカスタマイザーを構成します。