diff --git a/pulsar-io/kinesis-kpl-shaded/pom.xml b/pulsar-io/kinesis-kpl-shaded/pom.xml
index 7ce8cdcc6e859..7bf98aba669cb 100644
--- a/pulsar-io/kinesis-kpl-shaded/pom.xml
+++ b/pulsar-io/kinesis-kpl-shaded/pom.xml
@@ -38,7 +38,7 @@
   -->
 
   <properties>
-    <amazon-kinesis-producer.version>1.0.4</amazon-kinesis-producer.version>
+    <amazon-kinesis-producer.version>1.0.6</amazon-kinesis-producer.version>
     <protobuf-java.version>4.29.0</protobuf-java.version>
   </properties>
 
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java
index 41228f1465fd8..4001bf54af9d8 100644
--- a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java
+++ b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/sinks/KinesisSinkTester.java
@@ -33,6 +33,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
+import java.util.concurrent.TimeUnit;
 import lombok.AllArgsConstructor;
 import lombok.Cleanup;
 import lombok.Data;
@@ -188,7 +189,10 @@ public void produceMessage(int numMessages, PulsarClient client,
 
     @Override
     public void validateSinkResult(Map<String, String> kvs) {
-        Awaitility.await().untilAsserted(() -> internalValidateSinkResult(kvs));
+        Awaitility.await()
+                .atMost(300, TimeUnit.SECONDS)
+                .pollInterval(2, TimeUnit.SECONDS)
+                .untilAsserted(() -> internalValidateSinkResult(kvs));
     }
 
     @SneakyThrows