From d49b320c0c413265f8f2feeb8f750f6fba2b9adf Mon Sep 17 00:00:00 2001
From: furq-aws <furq@amazon.com>
Date: Wed, 22 Mar 2023 14:01:08 -0700
Subject: [PATCH] Fix flaky
 restartAfterRequestTimerExpiresWhenNotGettingRecordsAfterInitialization test

Add wait to allow RecordPublisherWithInitialFailureSubscription to start.
---
 .../amazon/kinesis/lifecycle/ShardConsumerSubscriberTest.java    | 1 +
 1 file changed, 1 insertion(+)

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 78e09fa1..0a40271e 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
@@ -339,6 +339,7 @@ public class ShardConsumerSubscriberTest {
         // First try to start subscriptions.
         synchronized (processedNotifier) {
             subscriber.startSubscriptions();
+            processedNotifier.wait(10);
         }
 
         // Verifying that there are no interactions with shardConsumer mock indicating no records were sent back and