Class RecoveringDeserializationExceptionHandler

java.lang.Object
org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler
All Implemented Interfaces:
org.apache.kafka.common.Configurable, org.apache.kafka.streams.errors.DeserializationExceptionHandler
public class RecoveringDeserializationExceptionHandler extends Object implements org.apache.kafka.streams.errors.DeserializationExceptionHandler
A DeserializationExceptionHandler that calls a ConsumerRecordRecoverer. and continues.
Since:
2.3
Author:
Gary Russell, Soby Chacko

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.apache.kafka.streams.errors.DeserializationExceptionHandler

    org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse, org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response, org.apache.kafka.streams.errors.DeserializationExceptionHandler.Result

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    KSTREAM_DESERIALIZATION_RECOVERER
    Property name for configuring the recoverer using properties.

  • Constructor Summary

    Constructors
    Constructor
    Description
    RecoveringDeserializationExceptionHandler()
     
    RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer recoverer)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    configure(Map<String,?> 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, Exception exception)
    Deprecated, for removal: This API element is subject to removal in a future version.
    since 4.1 in favor of handleError(ErrorHandlerContext, ConsumerRecord, Exception).
    org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response
    handleError(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, Exception exception)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.kafka.streams.errors.DeserializationExceptionHandler

    handle

  • Field Details

    • KSTREAM_DESERIALIZATION_RECOVERER

      public static final String KSTREAM_DESERIALIZATION_RECOVERER
      Property name for configuring the recoverer using properties.
      See Also:

  • Constructor Details

    • RecoveringDeserializationExceptionHandler

      public RecoveringDeserializationExceptionHandler()

    • RecoveringDeserializationExceptionHandler

      public RecoveringDeserializationExceptionHandler(ConsumerRecordRecoverer recoverer)

  • Method Details

    • handle

      @Deprecated(since="4.1", forRemoval=true) 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, Exception exception)
      Deprecated, for removal: This API element is subject to removal in a future version.
      since 4.1 in favor of handleError(ErrorHandlerContext, ConsumerRecord, Exception).
      Handle the deserialization exception by delegating to the configured recoverer.
      Specified by:
      handle in interface org.apache.kafka.streams.errors.DeserializationExceptionHandler

    • handleError

      public org.apache.kafka.streams.errors.DeserializationExceptionHandler.Response handleError(org.apache.kafka.streams.errors.ErrorHandlerContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> record, Exception exception)
      Specified by:
      handleError in interface org.apache.kafka.streams.errors.DeserializationExceptionHandler

    • configure

      public void configure(Map<String,?> configs)
      Specified by:
      configure in interface org.apache.kafka.common.Configurable