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

クラス 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

  • フィールドの詳細

    • 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.processor.ProcessorContext 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