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

クラス SeekUtils

java.lang.ObjectSE
org.springframework.kafka.listener.SeekUtils
public final class SeekUtils extends ObjectSE
ユーティリティを探します。
導入:
2.2
作成者:
Gary Russell, Francois Rosiere, Wang Zhiyang

  • フィールドの詳細

    • DEFAULT_MAX_FAILURES

      public static final int DEFAULT_MAX_FAILURES
      トピック / パーティション / オフセットが拒否される前に失敗する可能性がある回数。
      関連事項:

    • DEFAULT_BACK_OFF

      public static final FixedBackOff DEFAULT_BACK_OFF
      デフォルトのバックオフ - 0 間隔の FixedBackOff と DEFAULT_MAX_FAILURES - 1 回の再試行。

  • メソッドの詳細

    • doSeeks

      public static boolean doSeeks(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, ExceptionSE exception, boolean recoverable, BiPredicateSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,ExceptionSE> skipper, LogAccessor logger)
      レコードを最も早い位置にシークし、オプションで最初の位置をスキップします。
      パラメーター:
      records - 記録。
      consumer - コンシューマー。
      exception - 例外
      recoverable - 最初のレコードのスキップが許可されている場合は true。
      skipper - 最初のシークをスキップするかどうかを決定する関数。
      logger - シークエラーの LogAccessor。
      戻り値:
      失敗したレコードがスキップされた場合は true。

    • doSeeks

      public static boolean doSeeks(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, ExceptionSE exception, boolean recoverable, RecoveryStrategy recovery, @Nullable MessageListenerContainer container, LogAccessor logger)
      レコードを最も早い位置にシークし、オプションで最初の位置をスキップします。
      パラメーター:
      records - 記録。
      consumer - コンシューマー。
      exception - 例外
      recoverable - 最初のレコードのスキップが許可されている場合は true。
      recovery - RecoveryStrategy
      container - コンテナー、または子の場合は親。
      logger - シークエラーの LogAccessor。
      戻り値:
      失敗したレコードがスキップされた場合は true。

    • doSeeksToBegin

      public static void doSeeksToBegin(ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, LogAccessor logger)
      開始位置までレコードをシークします。オプションで最初のレコードをスキップします。
      パラメーター:
      records - 記録。
      consumer - コンシューマー。
      logger - シークエラーの LogAccessor。
      導入:
      3.2

    • seekPartitions

      public static void seekPartitions(org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MapSE<org.apache.kafka.common.TopicPartition,LongSE> partitions, LogAccessor logger)
      各パーティションでシーク操作を実行します。
      パラメーター:
      consumer - コンシューマー。
      partitions - パーティション。
      logger - ロガー。
      導入:
      2.5

    • seekOrRecover

      public static void seekOrRecover(ExceptionSE thrownException, ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, boolean commitRecovered, BiPredicateSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,ExceptionSE> skipPredicate, LogAccessor logger, KafkaException.Level level)
      残りのレコードを探し、オプションで最初のレコードを回復します。
      パラメーター:
      thrownException - 例外。
      records - 残りのレコード。
      consumer - コンシューマー。
      container - コンテナー。
      commitRecovered - 復元されたレコードのオフセットをコミットする場合は true。
      skipPredicate - スキップ述語。
      logger - ロガー。
      level - 処理後にスローされた例外のログレベル。
      導入:
      2.5

    • seekOrRecover

      public static void seekOrRecover(ExceptionSE thrownException, @Nullable ListSE<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, boolean commitRecovered, RecoveryStrategy recovery, LogAccessor logger, KafkaException.Level level)
      残りのレコードを探し、オプションで最初のレコードを回復します。
      パラメーター:
      thrownException - 例外。
      records - 残りのレコード。
      consumer - コンシューマー。
      container - コンテナー。
      commitRecovered - 復元されたレコードのオフセットをコミットする場合は true。
      recovery - RecoveryStrategy
      logger - ロガー。
      level - 処理後にスローされた例外のログレベル。
      導入:
      2.7

    • isBackoffException

      public static boolean isBackoffException(ExceptionSE exception)
      例外が KafkaBackoffException の場合、true を返します。
      パラメーター:
      exception - 例外。
      戻り値:
      それがバックオフの場合は true。
      導入:
      2.7