Class SeekToCurrentBatchErrorHandler

    • Constructor Detail

      • SeekToCurrentBatchErrorHandler

        public SeekToCurrentBatchErrorHandler()
    • Method Detail

      • setBackOff

        public void setBackOff​(org.springframework.util.backoff.BackOff backOff)
        Set a BackOff to suspend the thread after performing the seek. Since this error handler can never "recover" after retries are exhausted, if the back off returns STOP, then the previous interval is used.
        backOff - the back off.
      • clearThreadState

        public void clearThreadState()
        Description copied from interface: GenericErrorHandler
        Optional method to clear thread state; will be called just before a consumer thread terminates.
        Specified by:
        clearThreadState in interface GenericErrorHandler<org.apache.kafka.clients.consumer.ConsumerRecords<?,​?>>