Skip to content

Commit c6453f1

Browse files
committed
fix(test): use correct KDS maxBytesPerBatch (10 MiB) in all test files
All test files were using 5 MiB for maxBytesPerBatch, but the KDS default was 10 MiB (matching maxRecordSizeBytes). This mismatch caused getRecordsByStream to filter out records at the max size limit.
1 parent 2496a74 commit c6453f1

5 files changed

Lines changed: 6 additions & 6 deletions

File tree

packages/kinesis/amplify_kinesis_dart/test/in_memory_record_storage_test.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ void main() {
1515
storage = InMemoryRecordStorage(
1616
maxCacheBytes: 10 * 1024 * 1024,
1717
maxRecordsPerBatch: 500,
18-
maxBytesPerBatch: 5 * 1024 * 1024,
18+
maxBytesPerBatch: 10 * 1024 * 1024,
1919
maxRecordSizeBytes: 10 * 1024 * 1024,
2020
);
2121
});

packages/kinesis/amplify_kinesis_dart/test/record_client_concurrent_flush_test.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ void main() {
2626
database: db,
2727
maxCacheBytes: 1024 * 1024,
2828
maxRecordsPerBatch: 500,
29-
maxBytesPerBatch: 5 * 1024 * 1024,
29+
maxBytesPerBatch: 10 * 1024 * 1024,
3030
maxRecordSizeBytes: 10 * 1024 * 1024,
3131
);
3232
final sender = _GatedSender();

packages/kinesis/amplify_kinesis_dart/test/record_client_test.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ void main() {
3131
database: db,
3232
maxCacheBytes: 1024,
3333
maxRecordsPerBatch: 500,
34-
maxBytesPerBatch: 5 * 1024 * 1024,
34+
maxBytesPerBatch: 10 * 1024 * 1024,
3535
maxRecordSizeBytes: 10 * 1024 * 1024,
3636
);
3737
mockSender = MockKinesisSender();

packages/kinesis/amplify_kinesis_dart/test/record_validation_test.dart

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ void main() {
5252
database: db,
5353
maxCacheBytes: 10000,
5454
maxRecordsPerBatch: 500,
55-
maxBytesPerBatch: 5 * 1024 * 1024,
55+
maxBytesPerBatch: 10 * 1024 * 1024,
5656
maxRecordSizeBytes: 10 * 1024 * 1024,
5757
);
5858
client = createClient(storage: storage);
@@ -168,7 +168,7 @@ void main() {
168168
database: tightDb,
169169
maxCacheBytes: 80,
170170
maxRecordsPerBatch: 500,
171-
maxBytesPerBatch: 5 * 1024 * 1024,
171+
maxBytesPerBatch: 10 * 1024 * 1024,
172172
maxRecordSizeBytes: 10 * 1024 * 1024,
173173
);
174174
final tightClient = createClient(storage: tightStorage);

packages/kinesis/amplify_kinesis_dart/test/sqlite_record_storage_cache_accuracy_test.dart

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ void main() {
2626
database: db,
2727
maxCacheBytes: 1024 * 1024,
2828
maxRecordsPerBatch: 500,
29-
maxBytesPerBatch: 5 * 1024 * 1024,
29+
maxBytesPerBatch: 10 * 1024 * 1024,
3030
maxRecordSizeBytes: 10 * 1024 * 1024,
3131
);
3232
});

0 commit comments

Comments
 (0)