クラス RetryTopicComponentFactory

メソッドの詳細

• retryTopicConfigurer

  public RetryTopicConfigurer retryTopicConfigurer(DestinationTopicProcessor destinationTopicProcessor, ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer, ListenerContainerFactoryResolver factoryResolver, RetryTopicNamesProviderFactory retryTopicNamesProviderFactory)

  適切な RetryTopicConfiguration を処理することにより、特定の KafkaListenerEndpoint のノンブロッキングトピックベースの遅延再試行を構成するためのエントリポイントとして機能する RetryTopicConfigurer を作成します。

  パラメーター:

  destinationTopicProcessor - DestinationTopic インスタンスを処理し、DestinationTopicContainer に登録するために使用される DestinationTopicProcessor。

  listenerContainerFactoryConfigurer - ノンブロッキング遅延再試行機能用に KafkaListenerContainerFactory インスタンスを構成するために使用される ListenerContainerFactoryConfigurer。

  factoryResolver - 特定のエンドポイントまたはその再試行トピックの適切な KafkaListenerContainerFactory を解決するために使用される ListenerContainerFactoryResolver。

  retryTopicNamesProviderFactory - 再試行トピックのエンドポイントのプロパティ名を提供するために使用される RetryTopicNamesProviderFactory。

  戻り値:

  インスタンス。

• destinationTopicProcessor

  public DestinationTopicProcessor destinationTopicProcessor(DestinationTopicResolver destinationTopicResolver)

  DestinationTopic インスタンスの処理に使用される DestinationTopicProcessor を作成し、提供された DestinationTopicResolver に格納します。

  パラメーター:

  destinationTopicResolver - DestinationTopic インスタンスを格納するために使用される DestinationTopicResolver インスタンス。

  戻り値:

  インスタンス。

• destinationTopicResolver

  public DestinationTopicResolver destinationTopicResolver()

  DestinationTopic インスタンスを格納するために使用される DestinationTopicResolver のインスタンスを作成し、特定のレコードの転送先を解決します。

  戻り値:

  インスタンス。

• deadLetterPublishingRecovererFactory

  public DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory(DestinationTopicResolver destinationTopicResolver)

  レコードを特定の DestinationTopic に転送するための DeadLetterPublishingRecoverer の作成に使用される DeadLetterPublishingRecovererFactory を作成します。

  パラメーター:

  destinationTopicResolver - 宛先を解決するための DestinationTopicResolver インスタンス。

  戻り値:

  インスタンス。

• listenerContainerFactoryResolver

  public ListenerContainerFactoryResolver listenerContainerFactoryResolver(BeanFactory beanFactory)

  特定のトピックの適切な KafkaListenerContainerFactory を解決するために使用される ListenerContainerFactoryResolver を作成します。

  パラメーター:

  beanFactory - 必要に応じて KafkaListenerContainerFactory インスタンスを取得するために使用される BeanFactory。

  戻り値:

  インスタンス。

• listenerContainerFactoryConfigurer

  public ListenerContainerFactoryConfigurer listenerContainerFactoryConfigurer(KafkaConsumerBackoffManager kafkaConsumerBackoffManager, DeadLetterPublishingRecovererFactory deadLetterPublishingRecovererFactory, ClockSE clock)

  ListenerContainerFactoryResolver によって解決される KafkaListenerContainerFactory の構成に使用される ListenerContainerFactoryConfigurer を作成します。

  パラメーター:

  kafkaConsumerBackoffManager - KafkaBackoffAwareMessageListenerAdapter で使用される KafkaConsumerBackoffManager。

  deadLetterPublishingRecovererFactory - 使用する DeadLetterPublishingRecoverer インスタンスを提供するファクトリ。

  clock - リスナーアダプターで使用される ClockSE インスタンス。

  戻り値:

  インスタンス。

• retryTopicNamesProviderFactory

  public RetryTopicNamesProviderFactory retryTopicNamesProviderFactory()

  再試行トピックの KafkaListenerEndpoint のプロパティ名を提供するために使用される RetryTopicNamesProviderFactory インスタンスを作成します。

  戻り値:

  インスタンス。

• kafkaBackOffManagerFactory

  public KafkaBackOffManagerFactory kafkaBackOffManagerFactory(@Nullable ListenerContainerRegistry registry, ApplicationContext applicationContext)

  パーティションのバックオフに使用される KafkaConsumerBackoffManager インスタンスの作成に使用される KafkaBackOffManagerFactory を作成します。

  パラメーター:

  registry - MessageListenerContainer のフェッチに使用される ListenerContainerRegistry。

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

  戻り値:

  インスタンス。

• internalRetryTopicClock

  public ClockSE internalRetryTopicClock()

  トピックの再試行プロセスですべての時間関連操作に使用される ClockSE インスタンスを返します。

  戻り値:

  インスタンス。

• createInternalRetryTopicClock

  protected ClockSE createInternalRetryTopicClock()

  トピックの再試行プロセスで時間関連のすべての操作に使用される ClockSE インスタンスを作成します。

  戻り値:

  インスタンス。