Package org.springframework.kafka.streams

Class RecoveringDeserializationExceptionHandler

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

    • Nested Class Summary

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

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

    • Field Summary

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

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void configure​(java.util.Map<java.lang.String,​?> configs)  
      org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse handle​(org.apache.kafka.streams.processor.ProcessorContext context, org.apache.kafka.clients.consumer.ConsumerRecord<byte[],​byte[]> record, java.lang.Exception exception)  

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • KSTREAM_DESERIALIZATION_RECOVERER

        public static final java.lang.String KSTREAM_DESERIALIZATION_RECOVERER
        Property name for configuring the recoverer using properties.
        See Also:
        Constant Field Values

    • Constructor Detail

      • RecoveringDeserializationExceptionHandler

        public RecoveringDeserializationExceptionHandler()

      • RecoveringDeserializationExceptionHandler

        public RecoveringDeserializationExceptionHandler​(ConsumerRecordRecoverer recoverer)

    • Method Detail

      • 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,
                                                                                                             java.lang.Exception exception)
        Specified by:
        handle in interface org.apache.kafka.streams.errors.DeserializationExceptionHandler

      • configure

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