diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java index 7d0f9633..b628abe6 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java @@ -400,6 +400,7 @@ public class ShardConsumerSubscriberTest { // First try to start subscriptions. synchronized (processedNotifier) { subscriber.startSubscriptions(); + processedNotifier.wait(100); } // Verifying that there are no interactions with shardConsumer mock indicating no records were sent back and