org.thales.punch.kafka.api

Enum KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY

java.lang.Object

java.lang.Enum<KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY>

org.thales.punch.kafka.api.KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY

All Implemented Interfaces:

Serializable, Comparable<KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY>

Enclosing class:

KafkaContinuousConsumerBuilder<K,V>

public static enum KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY
extends Enum<KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY>

One of "earliest", "last_committed", "latest", "from_offset" or "from_timestamp". The latter requires an additional timestamp.

Author:

dimi

Enum Constant Summary

Enum Constants

Enum Constant and Description
EARLIEST Start from the earliest available record
FROM_DATETIME Start from corresponding timestamp as an unix epoch long value
FROM_OFFSET Start from the first record inserted after a given time
LAST_COMMITTED Start from the latest committed record
LATEST Start from the latest available record

Method Summary

Modifier and Type	Method and Description
static KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY	valueOf(String name) Returns the enum constant of this type with the specified name.
static KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY[]	values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

EARLIEST

public static final KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY EARLIEST

Start from the earliest available record

LATEST

public static final KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY LATEST

Start from the latest available record

LAST_COMMITTED

public static final KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY LAST_COMMITTED

Start from the latest committed record

FROM_OFFSET

public static final KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY FROM_OFFSET

Start from the first record inserted after a given time

FROM_DATETIME

public static final KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY FROM_DATETIME

Start from corresponding timestamp as an unix epoch long value

Method Detail

values

public static KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY c : KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY.values())
    System.out.println(c);

Returns:

an array containing the constants of this enum type, in the order they are declared

valueOf

public static KafkaContinuousConsumerBuilder.START_OFFSET_STRATEGY valueOf(String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum type has no constant with the specified name

NullPointerException - if the argument is null