diff --git a/cassandra/pom.xml b/cassandra/pom.xml
index 1f698a0c..60afd4a8 100644
--- a/cassandra/pom.xml
+++ b/cassandra/pom.xml
@@ -20,7 +20,7 @@
 		<module>util</module>
 		<module>example</module>
 		<module>java8</module>
-		<!--<module>reactive</module>-->
+		<module>reactive</module>
 	</modules>
 
 	<dependencies>
diff --git a/cassandra/reactive/src/main/java/example/springdata/cassandra/people/ApplicationConfiguration.java b/cassandra/reactive/src/main/java/example/springdata/cassandra/people/ApplicationConfiguration.java
index d3d023a3..0685d9fe 100644
--- a/cassandra/reactive/src/main/java/example/springdata/cassandra/people/ApplicationConfiguration.java
+++ b/cassandra/reactive/src/main/java/example/springdata/cassandra/people/ApplicationConfiguration.java
@@ -16,6 +16,7 @@
 package example.springdata.cassandra.people;
 
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.data.cassandra.CassandraDataAutoConfiguration;
 import org.springframework.data.cassandra.config.AbstractReactiveCassandraConfiguration;
 import org.springframework.data.cassandra.config.SchemaAction;
 import org.springframework.data.cassandra.repository.config.EnableReactiveCassandraRepositories;
@@ -25,7 +26,7 @@ import org.springframework.data.cassandra.repository.config.EnableReactiveCassan
  *
  * @author Mark Paluch
  */
-@SpringBootApplication
+@SpringBootApplication(exclude = CassandraDataAutoConfiguration.class)
 @EnableReactiveCassandraRepositories
 class ApplicationConfiguration extends AbstractReactiveCassandraConfiguration {
 
diff --git a/cassandra/reactive/src/test/java/example/springdata/cassandra/people/ReactiveCassandraTemplateIntegrationTest.java b/cassandra/reactive/src/test/java/example/springdata/cassandra/people/ReactiveCassandraTemplateIntegrationTest.java
index dd0383a2..c9aa4eb5 100644
--- a/cassandra/reactive/src/test/java/example/springdata/cassandra/people/ReactiveCassandraTemplateIntegrationTest.java
+++ b/cassandra/reactive/src/test/java/example/springdata/cassandra/people/ReactiveCassandraTemplateIntegrationTest.java
@@ -53,10 +53,11 @@ public class ReactiveCassandraTemplateIntegrationTest {
 	public void setUp() {
 
 		template.truncate(Person.class) //
-				.thenMany(template.insert(Flux.just(new Person("Walter", "White", 50), //
+				.thenMany(Flux.just(new Person("Walter", "White", 50), //
 						new Person("Skyler", "White", 45), //
 						new Person("Saul", "Goodman", 42), //
-						new Person("Jesse", "Pinkman", 27)))) //
+						new Person("Jesse", "Pinkman", 27))) //
+				.flatMap(template::insert) //
 				.then() //
 				.block();
 	}