diff --git a/lib/lambda/sinkMainProcessors.ts b/lib/lambda/sinkMainProcessors.ts
index 07ffafdf42..afafd48971 100644
--- a/lib/lambda/sinkMainProcessors.ts
+++ b/lib/lambda/sinkMainProcessors.ts
@@ -97,7 +97,7 @@ export const insertOneMacRecordsFromKafkaIntoMako = async (
 };
 
 const getMakoDocTimestamps = async (kafkaRecords: KafkaRecord[]) => {
-  const kafkaIds = kafkaRecords.map((record) => decodeBase64WithUtf8(record.key));
+  const kafkaIds = kafkaRecords.map((record) => JSON.stringify(decodeBase64WithUtf8(record.key)));
   const openSearchRecords = await getItems(kafkaIds);
 
   return openSearchRecords.reduce<Map<string, number>>((map, item) => {
@@ -129,7 +129,7 @@ export const insertNewSeatoolRecordsFromKafkaIntoMako = async (
           return collection;
         }
 
-        const id: string = decodeBase64WithUtf8(key);
+        const id: string = JSON.stringify(decodeBase64WithUtf8(key));
 
         console.log({ splitId: id.split(""), makoDocTimestamps });