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

クラス DestinationTopic.Properties

java.lang.ObjectSE
org.springframework.kafka.retrytopic.DestinationTopic.Properties
含まれているクラス:
DestinationTopic
public static class DestinationTopic.Properties extends ObjectSE

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

    • Properties

      public Properties(long delayMs, StringSE suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type, int maxAttempts, int numPartitions, DltStrategy dltStrategy, KafkaOperations<?,?> kafkaOperations, BiPredicateSE<IntegerSE,ThrowableSE> shouldRetryOn, long timeout)
      DLT コンテナーが自動的に起動するように、提供されたプロパティを使用してインスタンスを作成します（コンテナーファクトリがそのように構成されている場合）。
      パラメーター:
      delayMs - ミリ秒単位の遅延。
      suffix - 接尾辞。
      type - 型。
      maxAttempts - 最大試行回数。
      numPartitions - パーティションの数。
      dltStrategy - DLT 戦略。
      kafkaOperations - KafkaOperations
      shouldRetryOn - 例外分類。
      timeout - タイムアウト。

    • Properties

      public Properties(DestinationTopic.Properties sourceProperties, StringSE suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type)
      DLT コンテナーが自動的に起動する状態で、提供されたプロパティを使用してインスタンスを作成します。
      パラメーター:
      sourceProperties - ソースプロパティ。
      suffix - 接尾辞。
      type - 型。

    • Properties

      public Properties(long delayMs, StringSE suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type, int maxAttempts, int numPartitions, DltStrategy dltStrategy, KafkaOperations<?,?> kafkaOperations, BiPredicateSE<IntegerSE,ThrowableSE> shouldRetryOn, long timeout, @Nullable BooleanSE autoStartDltHandler)
      提供されたプロパティでインスタンスを作成します。
      パラメーター:
      delayMs - ミリ秒単位の遅延。
      suffix - 接尾辞。
      type - 型。
      maxAttempts - 最大試行回数。
      numPartitions - パーティションの数。
      dltStrategy - DLT 戦略。
      kafkaOperations - KafkaOperations
      shouldRetryOn - 例外分類。
      timeout - タイムアウト。
      autoStartDltHandler - DLT ハンドラーを開始するかどうか。
      導入:
      2.8

    • Properties

      public Properties(long delayMs, StringSE suffix, org.springframework.kafka.retrytopic.DestinationTopic.Type type, int maxAttempts, int numPartitions, DltStrategy dltStrategy, KafkaOperations<?,?> kafkaOperations, BiPredicateSE<IntegerSE,ThrowableSE> shouldRetryOn, long timeout, @Nullable BooleanSE autoStartDltHandler, SetSE<ClassSE<? extends ThrowableSE>> usedForExceptions)
      提供されたプロパティでインスタンスを作成します。
      パラメーター:
      delayMs - ミリ秒単位の遅延。
      suffix - 接尾辞。
      type - 型。
      maxAttempts - 最大試行回数。
      numPartitions - パーティションの数。
      dltStrategy - DLT 戦略。
      kafkaOperations - KafkaOperations
      shouldRetryOn - 例外分類。
      timeout - タイムアウト。
      autoStartDltHandler - DLT ハンドラーを開始するかどうか。
      usedForExceptions - 宛先が意図する例外
      導入:
      3.2

  • メソッドの詳細

    • isDltTopic

      public boolean isDltTopic()

    • isRetryTopic

      public boolean isRetryTopic()

    • suffix

      public StringSE suffix()

    • delay

      public long delay()

    • numPartitions

      public int numPartitions()
      再試行トピックを作成する必要のあるパーティションの数を返します。
      戻り値:
      パーティションの数。
      導入:
      2.7.13

    • autoStartDltHandler

      @Nullable public BooleanSE autoStartDltHandler()

    • usedForExceptions

      public SetSE<ClassSE<? extends ThrowableSE>> usedForExceptions()

    • equals

      public boolean equals(ObjectSE o)
      オーバーライド:
      クラス ObjectSE の equalsSE 

    • hashCode

      public int hashCode()
      オーバーライド:
      クラス ObjectSE の hashCode 

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString 

    • isMainEndpoint

      public boolean isMainEndpoint()