diff --git a/src/services/JobCandidateProcessorService.js b/src/services/JobCandidateProcessorService.js
index 0936815..837e42b 100644
--- a/src/services/JobCandidateProcessorService.js
+++ b/src/services/JobCandidateProcessorService.js
@@ -80,7 +80,7 @@ async function processCreate (message, transactionId) {
     index: config.get('esConfig.ES_INDEX_JOB_CANDIDATE'),
     id: jobcandidate.id,
     transactionId,
-    body: _.omit(jobcandidate, 'id'),
+    body: jobcandidate,
     refresh: constants.esRefreshOption
   })
 }
@@ -117,7 +117,7 @@ async function processUpdate (message, transactionId) {
     id: data.id,
     transactionId,
     body: {
-      doc: _.omit(data, ['id'])
+      doc: data
     },
     refresh: constants.esRefreshOption
   })
diff --git a/src/services/JobProcessorService.js b/src/services/JobProcessorService.js
index 72131ed..9350e52 100644
--- a/src/services/JobProcessorService.js
+++ b/src/services/JobProcessorService.js
@@ -51,7 +51,7 @@ async function processCreate (message, transactionId) {
     index: config.get('esConfig.ES_INDEX_JOB'),
     id: job.id,
     transactionId,
-    body: _.omit(job, 'id'),
+    body: job,
     refresh: constants.esRefreshOption
   })
   await postMessageToZapier({
@@ -99,7 +99,7 @@ async function processUpdate (message, transactionId) {
     id: data.id,
     transactionId,
     body: {
-      doc: _.omit(data, ['id'])
+      doc: data
     },
     refresh: constants.esRefreshOption
   })
diff --git a/src/services/ResourceBookingProcessorService.js b/src/services/ResourceBookingProcessorService.js
index 23b1de3..d7264bf 100644
--- a/src/services/ResourceBookingProcessorService.js
+++ b/src/services/ResourceBookingProcessorService.js
@@ -22,7 +22,7 @@ async function processCreate (message, transactionId) {
     index: config.get('esConfig.ES_INDEX_RESOURCE_BOOKING'),
     id: resourcebooking.id,
     transactionId,
-    body: _.omit(resourcebooking, 'id'),
+    body: resourcebooking,
     refresh: constants.esRefreshOption
   })
 }
@@ -63,7 +63,7 @@ async function processUpdate (message, transactionId) {
     id: data.id,
     transactionId,
     body: {
-      doc: _.omit(data, ['id'])
+      doc: data
     },
     refresh: constants.esRefreshOption
   })