パッケージ org.springframework.kafka.retrytopic

クラス ListenerContainerFactoryConfigurer

java.lang.ObjectSE
org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer
public class ListenerContainerFactoryConfigurer extends ObjectSE
提供された ConcurrentKafkaListenerContainerFactory を装飾して、DefaultErrorHandler および DeadLetterPublishingRecovererFactory によって作成された DeadLetterPublishingRecoverer を追加します。2.8.3 では、これらの構成は提供されたファクトリインスタンス自体に干渉しないため、同じファクトリインスタンスを再試行可能なエンドポイントと再試行不可能なエンドポイント間で共有できます。
導入:
2.7
作成者:
Tomaz Fernandes, Gary Russell, Wang Zhiyang

  • コンストラクターの詳細

  • メソッドの詳細

    • decorateFactory

      @DeprecatedSE(since="3.2", forRemoval=true) public KafkaListenerContainerFactory<?> decorateFactory(ConcurrentKafkaListenerContainerFactory<?,?> factory, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      付属の ConcurrentKafkaListenerContainerFactory を飾ります。
      パラメーター:
      factory - 装飾されるファクトリインスタンス。
      configuration - RetryTopicConfiguration によって提供される構成。
      戻り値:
      装飾されたファクトリインスタンス。

    • decorateFactoryWithoutSettingContainerProperties

      @DeprecatedSE(since="3.2", forRemoval=true) public KafkaListenerContainerFactory<?> decorateFactoryWithoutSettingContainerProperties(ConcurrentKafkaListenerContainerFactory<?,?> factory, org.springframework.kafka.retrytopic.ListenerContainerFactoryConfigurer.Configuration configuration)
      非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
      付属の ConcurrentKafkaListenerContainerFactory を飾ります。このメソッドはメインエンドポイントに使用されることを意図しており、提供された backOff 値を無視します。
      パラメーター:
      factory - 装飾されるファクトリインスタンス。
      configuration - RetryTopicConfiguration によって提供される構成。
      戻り値:
      装飾されたファクトリインスタンス。

    • decorateFactory

      public KafkaListenerContainerFactory<?> decorateFactory(ConcurrentKafkaListenerContainerFactory<?,?> factory)
      付属の ConcurrentKafkaListenerContainerFactory を飾ります。
      パラメーター:
      factory - 装飾されるファクトリインスタンス。
      戻り値:
      装飾されたファクトリインスタンス。
      導入:
      3.2

    • setBlockingRetriesBackOff

      public void setBlockingRetriesBackOff(BackOff blockingBackOff)
      ブロック再試行で使用される BackOff を設定します。BackOff の実行が STOP を返す場合、ノンブロッキング再試行の構成方法に応じて、レコードは次の再試行トピックまたは DLT に転送されます。
      パラメーター:
      blockingBackOff - 再試行をブロックすることによって使用される BackOff ポリシー。
      導入:
      2.8.4
      関連事項:

    • setBlockingRetryableExceptions

      @SafeVarargsSE public final void setBlockingRetryableExceptions(ClassSE<? extends ExceptionSE>... exceptionTypes)
      ブロッキングを介して再試行する例外を指定します。
      パラメーター:
      exceptionTypes - 再試行する必要がある例外。
      導入:
      2.8.4
      関連事項:

    • setRetainStandardFatal

      public void setRetainStandardFatal(boolean retainStandardFatal)
      ブロック再試行を構成するときに、標準の致命的な例外を再試行不可として保持するには、true に設定します。
      パラメーター:
      retainStandardFatal - 標準の致命的な例外を保持する場合は true。
      導入:
      3.0

    • setContainerCustomizer

      public void setContainerCustomizer(ConsumerSE<ConcurrentMessageListenerContainer<?,?>> containerCustomizer)

    • setErrorHandlerCustomizer

      public void setErrorHandlerCustomizer(ConsumerSE<DefaultErrorHandler> errorHandlerCustomizer)

    • createErrorHandler

      protected CommonErrorHandler createErrorHandler(DeadLetterPublishingRecoverer deadLetterPublishingRecoverer)

    • createDefaultErrorHandlerInstance

      protected DefaultErrorHandler createDefaultErrorHandlerInstance(DeadLetterPublishingRecoverer deadLetterPublishingRecoverer)

    • setupBackoffAwareMessageListenerAdapter

      protected void setupBackoffAwareMessageListenerAdapter(ConcurrentMessageListenerContainer<?,?> container)