@Generated(value="jsii-pacmak/1.73.0 (build 6faeda3)", date="2023-01-31T18:36:54.635Z") public enum StartingPosition extends java.lang.Enum<StartingPosition>
Example:
import software.amazon.awscdk.services.secretsmanager.Secret; import software.amazon.awscdk.services.lambda.eventsources.SelfManagedKafkaEventSource; // The secret that allows access to your self hosted Kafka cluster Secret secret; Function myFunction; // The list of Kafka brokers String[] bootstrapServers = List.of("kafka-broker:9092"); // The Kafka topic you want to subscribe to String topic = "some-cool-topic"; myFunction.addEventSource(SelfManagedKafkaEventSource.Builder.create() .bootstrapServers(bootstrapServers) .topic(topic) .secret(secret) .batchSize(100) // default .startingPosition(StartingPosition.TRIM_HORIZON) .build());
Enum Constant and Description |
---|
LATEST
Start reading just after the most recent record in the shard, so that you always read the most recent data in the shard.
|
TRIM_HORIZON
Start reading at the last untrimmed record in the shard in the system, which is the oldest data record in the shard.
|
Modifier and Type | Method and Description |
---|---|
static StartingPosition |
valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static StartingPosition[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static final StartingPosition TRIM_HORIZON
public static final StartingPosition LATEST
public static StartingPosition[] values()
for (StartingPosition c : StartingPosition.values()) System.out.println(c);
public static StartingPosition valueOf(java.lang.String name)
name
- the name of the enum constant to be returned.java.lang.IllegalArgumentException
- if this enum type has no constant with the specified namejava.lang.NullPointerException
- if the argument is null