クラス RetryTopicConfigurationSupport

メソッドの詳細

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  例外:

  BeansException

• afterSingletonsInstantiated

  public void afterSingletonsInstantiated()

  次で指定:

  インターフェース SmartInitializingSingleton の afterSingletonsInstantiated 

• retryTopicConfigurer

  @Bean(name="org.springframework.kafka.retrytopic.internalRetryTopicConfigurer") public RetryTopicConfigurer retryTopicConfigurer(@Qualifier("org.springframework.kafka.config.internalKafkaConsumerBackOffManager") KafkaConsumerBackoffManager kafkaConsumerBackoffManager, @Qualifier("org.springframework.kafka.retrytopic.internalDestinationTopicResolver") DestinationTopicResolver destinationTopicResolver, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, BeanFactory beanFactory)

  対応する RetryTopicConfiguration を持つ KafkaListenerEndpoint インスタンスの再試行トピックを構成するためのグローバル RetryTopicConfigurer を返します。これを構成するには、configureRetryTopicConfigurer() をオーバーライドすることを検討してください。

  パラメーター:

  kafkaConsumerBackoffManager - グローバル KafkaConsumerBackoffManager。

  destinationTopicResolver - グローバル DestinationTopicResolver。

  componentFactoryProvider - コンポーネントファクトリプロバイダ。

  beanFactory - BeanFactory

  戻り値:

  インスタンス。

  関連事項:

  • KafkaListenerAnnotationBeanPostProcessor

• configureRetryTopicConfigurer

  protected ConsumerSE<RetryTopicConfigurer> configureRetryTopicConfigurer()

  RetryTopicConfigurer を構成する必要がある場合は、このメソッドをオーバーライドします。

  戻り値:

  RetryTopicConfigurer コンシューマー。

• configureDeadLetterPublishingContainerFactory

  protected ConsumerSE<DeadLetterPublishingRecovererFactory> configureDeadLetterPublishingContainerFactory()

  DeadLetterPublishingRecovererFactory をさらに構成するには、このメソッドをオーバーライドします。

  戻り値:

  DeadLetterPublishingRecovererFactory コンシューマー。

• configureListenerContainerFactoryConfigurer

  protected ConsumerSE<ListenerContainerFactoryConfigurer> configureListenerContainerFactoryConfigurer()

  ListenerContainerFactoryConfigurer をさらに構成するには、このメソッドをオーバーライドします。

  戻り値:

  ListenerContainerFactoryConfigurer コンシューマー。

• configureBlockingRetries

  protected void configureBlockingRetries(RetryTopicConfigurationSupport.BlockingRetriesConfigurer blockingRetries)

  このメソッドをオーバーライドして、再試行する例外や使用する BackOff などのブロック再試行パラメーターを構成します。

  パラメーター:

  blockingRetries - RetryTopicConfigurationSupport.BlockingRetriesConfigurer。

• manageNonBlockingFatalExceptions

  protected void manageNonBlockingFatalExceptions(ListSE<ClassSE<? extends ThrowableSE>> nonBlockingRetriesExceptions)

  非ブロック再試行の致命的な例外を管理するには、このメソッドをオーバーライドします。処理がこのリストに存在する例外をスローするレコードは、構成されている場合は DLT に直接転送され、構成されていない場合は処理が停止されます。

  パラメーター:

  nonBlockingRetriesExceptions - フレームワークのデフォルトを含む致命的な例外の ListSE。

• configureCustomizers

  protected void configureCustomizers(RetryTopicConfigurationSupport.CustomizersConfigurer customizersConfigurer)

  このメソッドをオーバーライドして、MessageListenerContainer、DeadLetterPublishingRecoverer、DefaultErrorHandler などのノンブロッキング再試行の構成によって作成されたコンポーネントのカスタマイザーを構成します。

  パラメーター:

  customizersConfigurer - RetryTopicConfigurationSupport.CustomizersConfigurer。

• destinationTopicResolver

  @Bean(name="org.springframework.kafka.retrytopic.internalDestinationTopicResolver") public DestinationTopicResolver destinationTopicResolver(ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider)

  特定の ConsumerRecord が再試行のために送信される DestinationTopic を解決するために、グローバル DestinationTopicResolver を返します。それを構成するには、これらの他のよりきめ細かい方法のいずれかをオーバーライドすることを検討してください。

  • 非ブロック再試行を構成するための manageNonBlockingFatalExceptions(java.util.List<java.lang.Class<? extends java.lang.Throwable>>)。
  • コンポーネントをさらにカスタマイズするための configureDestinationTopicResolver()。
  • サブクラスのインスタンスを提供する createComponentFactory()。

  パラメーター:

  componentFactoryProvider - コンポーネントファクトリプロバイダ。

  戻り値:

  インスタンス。

• configureDestinationTopicResolver

  protected ConsumerSE<DestinationTopicResolver> configureDestinationTopicResolver()

  このメソッドをオーバーライドして、DestinationTopicResolver を構成します。

  戻り値:

  DestinationTopicResolver コンシューマー。

• kafkaConsumerBackoffManager

  @Bean(name="org.springframework.kafka.config.internalKafkaConsumerBackOffManager") public KafkaConsumerBackoffManager kafkaConsumerBackoffManager(ApplicationContext applicationContext, @Qualifier("org.springframework.kafka.config.internalKafkaListenerEndpointRegistry") @Nullable ListenerContainerRegistry registry, ObjectProvider<RetryTopicComponentFactory> componentFactoryProvider, @Nullable RetryTopicSchedulerWrapper wrapper, @Nullable TaskScheduler taskScheduler)

  パーティションのバックオフに使用される KafkaConsumerBackoffManager インスタンスを作成します。カスタム実装を提供するには、このメソッドをオーバーライドするか、RetryTopicComponentFactory.kafkaBackOffManagerFactory(org.springframework.kafka.listener.ListenerContainerRegistry, org.springframework.context.ApplicationContext) メソッドをオーバーライドして別の KafkaBackOffManagerFactory を返します。

  パラメーター:

  applicationContext - アプリケーションコンテキスト。

  registry - 実行時に MessageListenerContainer をフェッチするために使用される ListenerContainerRegistry はバックオフされます。

  componentFactoryProvider - コンポーネントファクトリプロバイダ。

  wrapper - RetryTopicSchedulerWrapper。

  taskScheduler - TaskScheduler。

  戻り値:

  インスタンス。

• createComponentFactory

  protected RetryTopicComponentFactory createComponentFactory()

  このメソッドをオーバーライドして、RetryTopicComponentFactory のサブクラスに異なるコンポーネント実装またはサブクラスを提供します。

  戻り値:

  インスタンス。