diff --git a/consumer/spring-jdbc-consumer/src/test/java/org/springframework/cloud/fn/consumer/jdbc/BatchInsertTimeoutTests.java b/consumer/spring-jdbc-consumer/src/test/java/org/springframework/cloud/fn/consumer/jdbc/BatchInsertTimeoutTests.java
index bd790aac..0c4c56c8 100644
--- a/consumer/spring-jdbc-consumer/src/test/java/org/springframework/cloud/fn/consumer/jdbc/BatchInsertTimeoutTests.java
+++ b/consumer/spring-jdbc-consumer/src/test/java/org/springframework/cloud/fn/consumer/jdbc/BatchInsertTimeoutTests.java
@@ -16,6 +16,8 @@
 
 package org.springframework.cloud.fn.consumer.jdbc;
 
+import java.time.Duration;
+
 import org.awaitility.Awaitility;
 import org.junit.jupiter.api.Test;
 
@@ -43,7 +45,7 @@ public class BatchInsertTimeoutTests extends JdbcConsumerApplicationTests {
 			final Message<Payload> message = MessageBuilder.withPayload(sent).build();
 			jdbcConsumer.accept(message);
 		}
-		Awaitility.await()
+		Awaitility.await().atMost(Duration.ofSeconds(30))
 			.until(() -> jdbcOperations.queryForObject("select count(*) from messages", Integer.class),
 					(value) -> value == numberOfInserts);
 	}