diff --git a/src/main/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/domain/KafkaModuleFactory.java b/src/main/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/domain/KafkaModuleFactory.java
index ab78ae73456..778bb124496 100644
--- a/src/main/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/domain/KafkaModuleFactory.java
+++ b/src/main/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/domain/KafkaModuleFactory.java
@@ -38,7 +38,7 @@ public JHipsterModule buildModule(JHipsterModuleProperties properties) {
         .add(SOURCE.template("KafkaConfiguration.java"), toSrcMainJava().append("/technical/infrastructure/config/kafka/KafkaConfiguration.java"))
         .and()
       .mandatoryReplacements()
-        .in(TEST_JAVA + "/IntegrationTest.java")
+        .in(TEST_JAVA + "/" + properties.basePackage().path() + "/IntegrationTest.java")
           .add(text("import org.springframework.boot.test.context.SpringBootTest;"), importExtendWith())
           .add(text("public @interface"), extendWith())
           .and()
diff --git a/src/test/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/domain/KafkaModuleFactoryTest.java b/src/test/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/domain/KafkaModuleFactoryTest.java
index da12c75395f..08754582722 100644
--- a/src/test/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/domain/KafkaModuleFactoryTest.java
+++ b/src/test/java/tech/jhipster/lite/generator/server/springboot/broker/kafka/domain/KafkaModuleFactoryTest.java
@@ -45,7 +45,7 @@ void shouldBuildKafkaModule() {
       pomFile(),
       new ModuleFile(
         "src/main/resources/generator/server/springboot/core/IntegrationTest.java.mustache",
-        TEST_JAVA + "/IntegrationTest.java"
+        TEST_JAVA + "/" + properties.basePackage().path() + "/IntegrationTest.java"
       ),
       readmeFile()
     )
@@ -72,7 +72,7 @@ void shouldBuildKafkaModule() {
       .containing("kafka.producer.value.serializer=org.apache.kafka.common.serialization.StringSerializer")
       .containing("kafka.polling.timeout=10000")
       .and()
-      .createFile(TEST_JAVA + "/IntegrationTest.java")
+      .createFile(TEST_JAVA + "/" + properties.basePackage().path() + "/IntegrationTest.java")
       .containing("@ExtendWith(KafkaTestContainerExtension.class)")
       .and()
       .createFile(MAIN_JAVA + "/" + TECHNICAL_INFRASTRUCTURE_CONFIG + "/kafka/KafkaProperties.java")