diff --git a/src/test/java/org/folio/indexing/IndexingCampusesConsortiumIT.java b/src/test/java/org/folio/indexing/IndexingCampusesConsortiumIT.java
index 8d2f3801a..3aa4de2ce 100644
--- a/src/test/java/org/folio/indexing/IndexingCampusesConsortiumIT.java
+++ b/src/test/java/org/folio/indexing/IndexingCampusesConsortiumIT.java
@@ -14,7 +14,6 @@
 import static org.folio.support.TestConstants.CENTRAL_TENANT_ID;
 import static org.folio.support.TestConstants.MEMBER_TENANT_ID;
 import static org.folio.support.TestConstants.inventoryCampusTopic;
-import static org.folio.support.TestConstants.inventoryLibraryTopic;
 import static org.folio.support.utils.JsonTestUtils.toMap;
 import static org.folio.support.utils.TestUtils.kafkaResourceEvent;
 import static org.folio.support.utils.TestUtils.randomId;
@@ -134,7 +133,7 @@ void shouldIgnoreShadowInstitution() {
     }).when(kafkaMessageListener).handleLocationEvents(anyList());
 
     var libraryEvent = kafkaResourceEvent(CENTRAL_TENANT_ID, CREATE, libraryMap, null);
-    kafkaTemplate.send(inventoryLibraryTopic(MEMBER_TENANT_ID), libraryEvent);
+    kafkaTemplate.send(inventoryCampusTopic(MEMBER_TENANT_ID), libraryEvent);
 
     await().atMost(ONE_MINUTE)
       .pollInterval(ONE_HUNDRED_MILLISECONDS)
diff --git a/src/test/java/org/folio/indexing/IndexingInstitutionsConsortiumIT.java b/src/test/java/org/folio/indexing/IndexingInstitutionsConsortiumIT.java
index 844ec9201..5fcb94e7b 100644
--- a/src/test/java/org/folio/indexing/IndexingInstitutionsConsortiumIT.java
+++ b/src/test/java/org/folio/indexing/IndexingInstitutionsConsortiumIT.java
@@ -13,7 +13,6 @@
 import static org.folio.support.TestConstants.CENTRAL_TENANT_ID;
 import static org.folio.support.TestConstants.MEMBER_TENANT_ID;
 import static org.folio.support.TestConstants.inventoryInstitutionTopic;
-import static org.folio.support.TestConstants.inventoryLibraryTopic;
 import static org.folio.support.utils.JsonTestUtils.toMap;
 import static org.folio.support.utils.TestUtils.kafkaResourceEvent;
 import static org.folio.support.utils.TestUtils.randomId;
@@ -134,7 +133,7 @@ void shouldIgnoreShadowInstitution() {
     }).when(kafkaMessageListener).handleLocationEvents(anyList());
 
     var libraryEvent = kafkaResourceEvent(CENTRAL_TENANT_ID, CREATE, libraryMap, null);
-    kafkaTemplate.send(inventoryLibraryTopic(MEMBER_TENANT_ID), libraryEvent);
+    kafkaTemplate.send(inventoryInstitutionTopic(MEMBER_TENANT_ID), libraryEvent);
 
     await().atMost(ONE_MINUTE)
       .pollInterval(ONE_HUNDRED_MILLISECONDS)
diff --git a/src/test/java/org/folio/indexing/IndexingLocationsConsortiumIT.java b/src/test/java/org/folio/indexing/IndexingLocationsConsortiumIT.java
index 5a16d75d4..ea1818324 100644
--- a/src/test/java/org/folio/indexing/IndexingLocationsConsortiumIT.java
+++ b/src/test/java/org/folio/indexing/IndexingLocationsConsortiumIT.java
@@ -11,7 +11,6 @@
 import static org.folio.search.model.types.ResourceType.LOCATION;
 import static org.folio.support.TestConstants.CENTRAL_TENANT_ID;
 import static org.folio.support.TestConstants.MEMBER_TENANT_ID;
-import static org.folio.support.TestConstants.inventoryLibraryTopic;
 import static org.folio.support.TestConstants.inventoryLocationTopic;
 import static org.folio.support.utils.JsonTestUtils.toMap;
 import static org.folio.support.utils.TestUtils.kafkaResourceEvent;
@@ -107,7 +106,7 @@ void shouldIgnoreShadowInstitution() {
     }).when(kafkaMessageListener).handleLocationEvents(anyList());
 
     var libraryEvent = kafkaResourceEvent(CENTRAL_TENANT_ID, CREATE, libraryMap, null);
-    kafkaTemplate.send(inventoryLibraryTopic(MEMBER_TENANT_ID), libraryEvent);
+    kafkaTemplate.send(inventoryLocationTopic(MEMBER_TENANT_ID), libraryEvent);
 
     await().atMost(ONE_MINUTE)
       .pollInterval(ONE_HUNDRED_MILLISECONDS)