SpringSpring Kafka Advanced
What is SeekToCurrentErrorHandler (now DefaultErrorHandler) in Spring Kafka?
Reference answer
DefaultErrorHandler (formerly SeekToCurrentErrorHandler pre Spring Kafka 2.8) handles exceptions from @KafkaListener methods. On error, it seeks the consumer back to the failed record's offset (so it can be retried) and retries up to maxAttempts times. After exhausting retries, it can recover via a RecovererHandler (e.g., DeadLetterPublishingRecoverer to send to DLT). Supports backoff (FixedBackOff or ExponentialBackOff). Configure: containerFactory.setCommonErrorHandler(new DefaultErrorHandler(recoverer, new FixedBackOff(1000, 3))).
Expected key concepts: DefaultErrorHandler, SeekToCurrentErrorHandler, maxAttempts, RecovererHandler, DeadLetterPublishingRecoverer, FixedBackOff, ExponentialBackOff, seek, retry, DLT