diff --git a/spring-pulsar-spring-boot-autoconfigure/src/integration-test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java b/spring-pulsar-spring-boot-autoconfigure/src/integration-test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java
index 82ed07eb..6de3b9de 100644
--- a/spring-pulsar-spring-boot-autoconfigure/src/integration-test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java
+++ b/spring-pulsar-spring-boot-autoconfigure/src/integration-test/java/org/springframework/pulsar/autoconfigure/PulsarFunctionAdministrationIntegrationTests.java
@@ -162,6 +162,9 @@ class PulsarFunctionAdministrationIntegrationTests {
 			}
 		}
 
+		// Give app context time to close and run the stop policies
+		Thread.sleep(10000);
+
 		// Stop policy runs after context close - verify source are in expected state
 		try (PulsarAdmin admin = getAdmin()) {
 			assertSourceExistsWithStatus("rabbit-test-source-none", true, admin);