org.springframework.kafka.support

Class SeekUtils

java.lang.Object

org.springframework.kafka.support.SeekUtils

public final class SeekUtils
extends java.lang.Object

Seek utilities.

Since:

2.2

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field and Description
static org.springframework.util.backoff.FixedBackOff	DEFAULT_BACK_OFF The default back off - a FixedBackOff with 0 interval and DEFAULT_MAX_FAILURES - 1 retry attempts.
static int	DEFAULT_MAX_FAILURES The number of times a topic/partition/offset can fail before being rejected.

Method Summary

Modifier and Type

Method and Description

static boolean

doSeeks(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records, org.apache.kafka.clients.consumer.Consumer<?,?> consumer, java.lang.Exception exception, boolean recoverable, java.util.function.BiPredicate<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,java.lang.Exception> skipper, org.springframework.core.log.LogAccessor logger) Seek records to earliest position, optionally skipping the first.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_FAILURES

public static final int DEFAULT_MAX_FAILURES

The number of times a topic/partition/offset can fail before being rejected.

See Also:

Constant Field Values

DEFAULT_BACK_OFF

public static final org.springframework.util.backoff.FixedBackOff DEFAULT_BACK_OFF

The default back off - a FixedBackOff with 0 interval and DEFAULT_MAX_FAILURES - 1 retry attempts.

Method Detail

doSeeks

public static boolean doSeeks(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>> records,
                              org.apache.kafka.clients.consumer.Consumer<?,?> consumer,
                              java.lang.Exception exception,
                              boolean recoverable,
                              java.util.function.BiPredicate<org.apache.kafka.clients.consumer.ConsumerRecord<?,?>,java.lang.Exception> skipper,
                              org.springframework.core.log.LogAccessor logger)

Seek records to earliest position, optionally skipping the first.

Parameters:

records - the records.

consumer - the consumer.

exception - the exception

recoverable - true if skipping the first record is allowed.

skipper - function to determine whether or not to skip seeking the first.

logger - a LogAccessor for seek errors.

Returns:

true if the failed record was skipped.