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 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 void

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.apache.commons.logging.Log 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

Method Detail

doSeeks

public static void 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.apache.commons.logging.Log 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 Log for seek errors.