public enum FirstPollOffsetStrategy extends Enum<FirstPollOffsetStrategy>
Defines how the spout seeks the offset to be used in the first poll to Kafka upon topology deployment. By default this parameter is set to UNCOMMITTED_EARLIEST.
Enum Constant and Description |
---|
EARLIEST
The kafka spout polls records starting in the first offset of the partition, regardless of previous commits.
|
LATEST
The kafka spout polls records starting at the end of the partition, regardless of previous commits.
|
TIMESTAMP
The kafka spout polls records starting at the earliest offset whose timestamp is greater than or equal to the given startTimestamp.
|
UNCOMMITTED_EARLIEST
The kafka spout polls records from the last committed offset, if any.
|
UNCOMMITTED_LATEST
The kafka spout polls records from the last committed offset, if any.
|
UNCOMMITTED_TIMESTAMP
The kafka spout polls records from the last committed offset, if any.
|
Modifier and Type | Method and Description |
---|---|
static FirstPollOffsetStrategy |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static FirstPollOffsetStrategy[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final FirstPollOffsetStrategy EARLIEST
public static final FirstPollOffsetStrategy LATEST
public static final FirstPollOffsetStrategy TIMESTAMP
public static final FirstPollOffsetStrategy UNCOMMITTED_EARLIEST
public static final FirstPollOffsetStrategy UNCOMMITTED_LATEST
public static final FirstPollOffsetStrategy UNCOMMITTED_TIMESTAMP
public static FirstPollOffsetStrategy[] values()
for (FirstPollOffsetStrategy c : FirstPollOffsetStrategy.values()) System.out.println(c);
public static FirstPollOffsetStrategy 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 nullCopyright © 2022 The Apache Software Foundation. All rights reserved.