@Internal public enum StartupMode extends Enum<StartupMode>
Enum Constant and Description |
---|
EARLIEST
Start from the earliest offset possible.
|
GROUP_OFFSETS
Start from committed offsets in ZK / Kafka brokers of a specific consumer group (default).
|
LATEST
Start from the latest offset.
|
SPECIFIC_OFFSETS
Start from user-supplied specific offsets for each partition.
|
TIMESTAMP
Start from user-supplied timestamp for each partition.
|
Modifier and Type | Method and Description |
---|---|
long |
getStateSentinel() |
static StartupMode |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static StartupMode[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final StartupMode GROUP_OFFSETS
public static final StartupMode EARLIEST
public static final StartupMode LATEST
public static final StartupMode TIMESTAMP
public static final StartupMode SPECIFIC_OFFSETS
public static StartupMode[] values()
for (StartupMode c : StartupMode.values()) System.out.println(c);
public static StartupMode valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic long getStateSentinel()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.