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

クラス CommonLoggingErrorHandler

java.lang.ObjectSE
org.springframework.kafka.listener.CommonLoggingErrorHandler
実装されたすべてのインターフェース:
CommonErrorHandler, DeliveryAttemptAware
public class CommonLoggingErrorHandler extends ObjectSE implements CommonErrorHandler
例外をログに記録するための CommonErrorHandler 実装。
導入:
2.8
作成者:
Gary Russell

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

    • CommonLoggingErrorHandler

      public CommonLoggingErrorHandler()

  • メソッドの詳細

    • isAckAfterHandle

      public boolean isAckAfterHandle()
      インターフェースからコピーされた説明: CommonErrorHandler
      処理されたエラーに対してオフセットをコミットする必要がある場合は true を返します（例外はスローされません）。
      次で指定:
      インターフェース CommonErrorHandler の isAckAfterHandle 
      戻り値:
      コミットする場合は true。

    • setAckAfterHandle

      public void setAckAfterHandle(boolean ackAfterHandle)
      インターフェースからコピーされた説明: CommonErrorHandler
      コンテナーがリカバリされたレコードのオフセットをコミットしないようにするには、false に設定します（エラーハンドラー自体が例外をスローしない場合）。
      次で指定:
      インターフェース CommonErrorHandler の setAckAfterHandle 
      パラメーター:
      ackAfterHandle - コミットしない場合は false。

    • handleOne

      public boolean handleOne(ExceptionSE thrownException, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container)
      インターフェースからコピーされた説明: CommonErrorHandler
      CommonErrorHandler.seeksAfterHandling() が false を返した場合のレコードリスナーの例外を処理します。これを使用して、失敗した単一のレコードのみを処理します。
      次で指定:
      インターフェース CommonErrorHandler の handleOne 
      パラメーター:
      thrownException - 例外。
      record - レコード。
      consumer - コンシューマー。
      container - コンテナー。
      戻り値:
      エラーが「処理」された場合は true、そうでない場合は false で、コンテナーはレコードをリスナーに再送信します。
      関連事項:

    • handleBatch

      public void handleBatch(ExceptionSE thrownException, org.apache.kafka.clients.consumer.ConsumerRecords<?,?> data, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, RunnableSE invokeListener)
      インターフェースからコピーされた説明: CommonErrorHandler
      バッチリスナーの例外を処理します。ポーリングからの完全な ConsumerRecords が提供されます。バッチ内のレコードを再処理する場合は、エラーハンドラーがシークを実行する必要があります。
      次で指定:
      インターフェース CommonErrorHandler の handleBatch 
      パラメーター:
      thrownException - 例外。
      data - コンシューマーの記録。
      consumer - コンシューマー。
      container - コンテナー。
      invokeListener - リスナーを再起動するためのコールバック。

    • handleOtherException

      public void handleOtherException(ExceptionSE thrownException, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, MessageListenerContainer container, boolean batchListener)
      インターフェースからコピーされた説明: CommonErrorHandler
      利用可能なレコードがない状態で例外がスローされた場合に呼び出されます。コンシューマー投票が例外をスローした場合。
      次で指定:
      インターフェース CommonErrorHandler の handleOtherException 
      パラメーター:
      thrownException - 例外。
      consumer - コンシューマー。
      container - コンテナー。
      batchListener - リスナーがバッチリスナーの場合は true。