diff --git a/mod-source-record-storage-server/src/main/java/org/folio/verticle/consumers/DataImportConsumersVerticle.java b/mod-source-record-storage-server/src/main/java/org/folio/verticle/consumers/DataImportConsumersVerticle.java
index a4f020945..cf09ac98e 100644
--- a/mod-source-record-storage-server/src/main/java/org/folio/verticle/consumers/DataImportConsumersVerticle.java
+++ b/mod-source-record-storage-server/src/main/java/org/folio/verticle/consumers/DataImportConsumersVerticle.java
@@ -1,5 +1,6 @@
 package org.folio.verticle.consumers;
 
+import static org.folio.rest.jaxrs.model.DataImportEventTypes.DI_INCOMING_MARC_BIB_RECORD_PARSED;
 import static org.folio.rest.jaxrs.model.DataImportEventTypes.DI_INVENTORY_AUTHORITY_CREATED_READY_FOR_POST_PROCESSING;
 import static org.folio.rest.jaxrs.model.DataImportEventTypes.DI_INVENTORY_AUTHORITY_UPDATED_READY_FOR_POST_PROCESSING;
 import static org.folio.rest.jaxrs.model.DataImportEventTypes.DI_INVENTORY_HOLDINGS_CREATED_READY_FOR_POST_PROCESSING;
@@ -62,7 +63,8 @@ public class DataImportConsumersVerticle extends AbstractConsumerVerticle<String
     DI_SRS_MARC_BIB_RECORD_MATCHED.value(),
     DI_SRS_MARC_BIB_RECORD_MODIFIED.value(),
     DI_SRS_MARC_BIB_RECORD_NOT_MATCHED.value(),
-    DI_SRS_MARC_HOLDINGS_RECORD_MATCHED.value()
+    DI_SRS_MARC_HOLDINGS_RECORD_MATCHED.value(),
+    DI_INCOMING_MARC_BIB_RECORD_PARSED.value()
   );
 
   private final AsyncRecordHandler<String, byte[]> dataImportKafkaHandler;
diff --git a/ramls/raml-storage b/ramls/raml-storage
index e8d5264cb..7475f066f 160000
--- a/ramls/raml-storage
+++ b/ramls/raml-storage
@@ -1 +1 @@
-Subproject commit e8d5264cbf0f615b7a49645a6a2c8c6b93ed66b4
+Subproject commit 7475f066f83f956a7b715ac7c86c4942104197be