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

列挙型クラス ContainerProperties.AckMode

java.lang.ObjectSE
java.lang.EnumSE<ContainerProperties.AckMode>
org.springframework.kafka.listener.ContainerProperties.AckMode
実装されたすべてのインターフェース:
SerializableSE、ComparableSE<ContainerProperties.AckMode>、ConstableSE
含まれているクラス:
ContainerProperties
public static enum ContainerProperties.AckMode extends EnumSE<ContainerProperties.AckMode>
オフセットコミット動作の列挙。

  • ネストされたクラスのサマリー

    クラス java.lang.EnumSE から継承されたネストクラス / インターフェース

    Enum.EnumDescSE<ESE extends EnumSE<ESE>>

  • 列挙定数のサマリー

    列挙型定数
    列挙定数
    説明
    BATCH
    すべてのレコードがリスナーによって処理された後、前のポーリングによって返されたすべてのレコードのオフセットをコミットします。
    COUNT
    ackCount を超えた後、保留中のオフセットをコミットします。
    COUNT_TIME
    ackCount を超えた後、または ackTime が経過した後、保留中のオフセットをコミットします。
    MANUAL
    リスナーは acking に責任があります。AcknowledgingMessageListener を使用してください ; 前のポーリングによって返されたすべてのレコードがリスナーによって処理されると、ack がキューに入れられ、オフセットがコミットされます。
    MANUAL_IMMEDIATE
    リスナーは acking に責任があります。AcknowledgingMessageListener を使用してください ; Acknowledgment が呼び出し元のコンシューマースレッドで確認応答された場合、コミットはすぐに実行されます。それ以外の場合は、前のポーリングによって返されたすべてのレコードがリスナーによって処理されたときに、ack がキューに入れられ、オフセットがコミットされます。呼び出し元のスレッドで確認する場合としない場合がある場合、結果は不確定になります。
    RECORD
    各レコードがリスナーによって処理された後、オフセットをコミットします。
    TIME
    ackTime が経過した後、保留中のオフセットをコミットします。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    static ContainerProperties.AckMode
    valueOf(StringSE name)
    指定された名前でこのクラスの列挙型定数を返します。
    static ContainerProperties.AckMode[]
    values()
    この列挙型クラスの定数を含む配列を、宣言されている順序で返します。

    クラス java.lang.EnumSE から継承されたメソッド

    clone, compareToSE, describeConstable, equalsSE, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOfSE

    クラス java.lang.ObjectSE から継承されたメソッド

    getClass, notify, notifyAll, wait, waitSE, waitSE

  • 列挙型定数の詳細

    • RECORD

      public static final ContainerProperties.AckMode RECORD
      各レコードがリスナーによって処理された後、オフセットをコミットします。

    • BATCH

      public static final ContainerProperties.AckMode BATCH
      すべてのレコードがリスナーによって処理された後、前のポーリングによって返されたすべてのレコードのオフセットをコミットします。

    • TIME

      public static final ContainerProperties.AckMode TIME
      ackTime が経過した後、保留中のオフセットをコミットします。

    • COUNT

      public static final ContainerProperties.AckMode COUNT
      ackCount を超えた後、保留中のオフセットをコミットします。

    • COUNT_TIME

      public static final ContainerProperties.AckMode COUNT_TIME
      ackCount を超えた後、または ackTime が経過した後、保留中のオフセットをコミットします。

    • MANUAL

      public static final ContainerProperties.AckMode MANUAL
      リスナーは acking に責任があります。AcknowledgingMessageListener を使用してください ; 前のポーリングによって返されたすべてのレコードがリスナーによって処理されると、ack がキューに入れられ、オフセットがコミットされます。

    • MANUAL_IMMEDIATE

      public static final ContainerProperties.AckMode MANUAL_IMMEDIATE
      リスナーは acking に責任があります。AcknowledgingMessageListener を使用してください ; Acknowledgment が呼び出し元のコンシューマースレッドで確認応答された場合、コミットはすぐに実行されます。それ以外の場合は、前のポーリングによって返されたすべてのレコードがリスナーによって処理されたときに、ack がキューに入れられ、オフセットがコミットされます。呼び出し元のスレッドで確認する場合としない場合がある場合、結果は不確定になります。

  • メソッドの詳細

    • values

      public static ContainerProperties.AckMode[] values()
      この列挙型クラスの定数を含む配列を、宣言されている順序で返します。
      戻り値:
      この列挙型クラスの定数を宣言された順序で含む配列

    • valueOf

      public static ContainerProperties.AckMode valueOf(StringSE name)
      指定された名前でこのクラスの列挙型定数を返します。文字列は、このクラスで列挙型定数を宣言するために使用される識別子と正確に一致する必要があります。(余分な空白文字は許可されません。)
      パラメーター:
      name - 返される列挙定数の名前。
      戻り値:
      指定された名前の列挙定数
      例外:
      IllegalArgumentExceptionSE - この列挙型クラスに指定された名前の定数がない場合
      NullPointerExceptionSE - 引数が null の場合