@Internal public enum BoundedMode extends Enum<BoundedMode>
Enum Constant and Description |
---|
GROUP_OFFSETS
End from committed offsets in ZK / Kafka brokers of a specific consumer group.
|
LATEST
End from the latest offset.
|
SPECIFIC_OFFSETS
End from user-supplied specific offsets for each partition.
|
TIMESTAMP
End from user-supplied timestamp for each partition.
|
UNBOUNDED
Do not end consuming.
|
Modifier and Type | Method and Description |
---|---|
static BoundedMode |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static BoundedMode[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final BoundedMode UNBOUNDED
public static final BoundedMode GROUP_OFFSETS
public static final BoundedMode LATEST
public static final BoundedMode TIMESTAMP
public static final BoundedMode SPECIFIC_OFFSETS
public static BoundedMode[] values()
for (BoundedMode c : BoundedMode.values()) System.out.println(c);
public static BoundedMode 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 © 2014–2023 The Apache Software Foundation. All rights reserved.