diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java
index b5f93194d..5fddad0a7 100644
--- a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java
+++ b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/AsyncCassandraTemplateIntegrationTests.java
@@ -317,7 +317,7 @@ public class AsyncCassandraTemplateIntegrationTests extends AbstractKeyspaceCrea
 		for (int count = 0; count < 100; count++) {
 			User user = new User("heisenberg" + count, "Walter", "White");
 			expectedIds.add(user.getId());
-			template.insert(user);
+			getUninterruptibly(template.insert(user));
 		}
 
 		Set<String> ids = new HashSet<>();