diff --git a/integration-tests/integration-tests.gradle b/integration-tests/integration-tests.gradle
index 7a01affe..4001348d 100644
--- a/integration-tests/integration-tests.gradle
+++ b/integration-tests/integration-tests.gradle
@@ -13,6 +13,8 @@ repositories {
 }
 
 dependencies {
+	intTestImplementation project(':spring-pulsar')
+	intTestImplementation project(':spring-pulsar-reactive')
 	intTestImplementation project(':spring-pulsar-test')
 	intTestRuntimeOnly 'ch.qos.logback:logback-classic'
 	intTestRuntimeOnly 'org.junit.platform:junit-platform-launcher'
diff --git a/integration-tests/src/intTest/java/org/springframework/pulsar/inttest/listener/ReactivePulsarListenerIntegrationTests.java b/integration-tests/src/intTest/java/org/springframework/pulsar/inttest/listener/ReactivePulsarListenerIntegrationTests.java
index df9da62e..c883bedb 100644
--- a/integration-tests/src/intTest/java/org/springframework/pulsar/inttest/listener/ReactivePulsarListenerIntegrationTests.java
+++ b/integration-tests/src/intTest/java/org/springframework/pulsar/inttest/listener/ReactivePulsarListenerIntegrationTests.java
@@ -42,7 +42,7 @@ import org.springframework.pulsar.core.PulsarTemplate;
 import org.springframework.pulsar.core.SchemaResolver;
 import org.springframework.pulsar.core.TopicResolver;
 import org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener;
-import org.springframework.pulsar.reactive.core.ReactiveMessageConsumerBuilderCustomizer;
+import org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerMessageConsumerBuilderCustomizer;
 import org.springframework.pulsar.reactive.core.ReactivePulsarTemplate;
 import org.springframework.pulsar.test.support.PulsarTestContainerSupport;
 
@@ -221,7 +221,7 @@ class ReactivePulsarListenerIntegrationTests implements PulsarTestContainerSuppo
 	static class ConsumerCustomizerConfig {
 
 		@Bean
-		ReactiveMessageConsumerBuilderCustomizer<String> consumerCustomizer() {
+		ReactivePulsarListenerMessageConsumerBuilderCustomizer<String> consumerCustomizer() {
 			return b -> b.subscriptionInitialPosition(SubscriptionInitialPosition.Earliest);
 		}