Skip to content
Kafka Is FunProgress

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