diff --git a/src/main/java/hu/dpc/phee/operator/importer/RecordParser.java b/src/main/java/hu/dpc/phee/operator/importer/RecordParser.java
index d072570c..feba7f3d 100644
--- a/src/main/java/hu/dpc/phee/operator/importer/RecordParser.java
+++ b/src/main/java/hu/dpc/phee/operator/importer/RecordParser.java
@@ -314,7 +314,9 @@ private void updateTransferTableForBatch(Long workflowInstanceKey, Long complete
         for (Transaction transaction: transactionList) {
             Transfer transfer = BatchFormatToTransferMapper.mapToTransferEntity(transaction);
             transfer.setWorkflowInstanceKey(workflowInstanceKey);
-            transfer.setBatchId(strip(tempDocumentStore.getBatchId(workflowInstanceKey)));
+
+            String batchId = tempDocumentStore.getBatchId(workflowInstanceKey);
+            transfer.setBatchId(strip(batchId));
             transfer.setCompletedAt(new Date(completeTimestamp));
             transfer.setTransactionId(transaction.getRequestId());
 
@@ -327,7 +329,6 @@ private void updateTransferTableForBatch(Long workflowInstanceKey, Long complete
             transfer.setPayerFee(BigDecimal.ZERO);
 
             BatchFormatToTransferMapper.updateTransferUsingBatchDetails(transfer, batch);
-
             transferRepository.save(transfer);
         }
 
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 15837f91..f35ccd92 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -118,11 +118,13 @@ bpmn:
     - id: "mock_payment_transfer_debit"
       direction: "${bpmn.outgoing-direction}"
       type: "${bpmn.transfer-type}"
+    - id: "bulk_connector_closedloop"
+      direction: "UNKNOWN"
+      type: "${bpmn.batch-type}"
     - id: "minimal_mock_fund_transfer"
       direction: "${bpmn.outgoing-direction}"
       type: "${bpmn.transfer-type}"
 
-
 logging:
   level:
     ROOT: ERROR