File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
test/stability-tests/src/it/java/software/amazon/awssdk/stability/tests/kinesis Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -187,6 +187,9 @@ private List<CompletableFuture<?>> generateSubscribeToShardFutures() throws Inte
187
187
.startingPosition (s -> s .type (ShardIteratorType .TRIM_HORIZON )),
188
188
responseHandler )
189
189
.thenAccept (b -> {
190
+ // Only verify data if all events have been received and the received data is not empty.
191
+ // It is possible the received data is empty because there is no record at the position
192
+ // event with TRIM_HORIZON.
190
193
if (responseHandler .allEventsReceived && !responseHandler .receivedData .isEmpty ()) {
191
194
assertThat (producedData ).as (responseHandler .id + " has not received all events"
192
195
+ "." ).containsSequence (responseHandler .receivedData );
You can’t perform that action at this time.
0 commit comments