クラス RecoveringDeserializationExceptionHandler

java.lang.ObjectSE
org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
実装済みのインターフェース一覧:
org.apache.kafka.common.Configurable, org.apache.kafka.streams.errors.DeserializationExceptionHandler
public class RecoveringDeserializationExceptionHandler extends ObjectSE implements org.apache.kafka.streams.errors.DeserializationExceptionHandler
ConsumerRecordRecoverer を呼び出す DeserializationExceptionHandler。と続けます。
導入:
2.3
作成者:
Gary Russell

  • ネストされたクラスの概要

    インターフェース org.apache.kafka.streams.errors.DeserializationExceptionHandler から継承されたネストクラス / インターフェース

    org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse

  • フィールド概要

    フィールド
    修飾子と型
    フィールド
    説明
    static final StringSE
    KSTREAM_DESERIALIZATION_RECOVERER
    プロパティを使用して回復者を構成するためのプロパティ名。

  • コンストラクター概要

    コンストラクター
    コンストラクター
    説明
    RecoveringDeserializationExceptionHandler()
    RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer recoverer)

  • 方法の概要

    修飾子と型
    メソッド
    説明
    void
    configure(MapSE<StringSE,?> configs)
    org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse
    handle(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, ExceptionSE exception)

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

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

    インターフェース org.apache.kafka.streams.errors.DeserializationExceptionHandler から継承されたメソッド

    handle

  • フィールドの詳細

    • KSTREAM_DESERIALIZATION_RECOVERER

      public static final StringSE KSTREAM_DESERIALIZATION_RECOVERER
      プロパティを使用して回復者を構成するためのプロパティ名。
      関連事項:

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

    • RecoveringDeserializationExceptionHandler

      public RecoveringDeserializationExceptionHandler()

    • RecoveringDeserializationExceptionHandler

      public RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer recoverer)

  • メソッドの詳細

    • handle

      public org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse handle(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, ExceptionSE exception)
      次で指定:
      インターフェース org.apache.kafka.streams.errors.DeserializationExceptionHandler の handle 

    • configure

      public void configure(MapSE<StringSE,?> configs)
      次で指定:
      インターフェース org.apache.kafka.common.Configurable の configure