diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java index 9be05c43..41bab25b 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisClientLibConfiguration.java @@ -1290,7 +1290,13 @@ public class KinesisClientLibConfiguration { } public KinesisClientLibConfiguration withDataFetchingStrategy(String dataFetchingStrategy) { - recordsFetcherFactory.setDataFetchingStrategy(DataFetchingStrategy.valueOf(dataFetchingStrategy)); + switch (dataFetchingStrategy.toUpperCase()) { + case "PREFETCH_CACHED": + recordsFetcherFactory.setDataFetchingStrategy(DataFetchingStrategy.PREFETCH_CACHED); + break; + default: + recordsFetcherFactory.setDataFetchingStrategy(DataFetchingStrategy.DEFAULT); + } return this; }