diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java index 29ee7401..3a3958f3 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/SimpleRecordsFetcherFactory.java @@ -22,7 +22,7 @@ import lombok.extern.apachecommons.CommonsLog; public class SimpleRecordsFetcherFactory implements RecordsFetcherFactory { private final int maxRecords; private int maxSize = 3; - private int maxByteSize = 15 * 1024 * 1024; + private int maxByteSize = 8 * 1024 * 1024; private int maxRecordsCount = 30000; private DataFetchingStrategy dataFetchingStrategy = DataFetchingStrategy.DEFAULT;