fix: add JSON.stringify

Enterprise-CMCS · Dec 8, 2024 · 8bd3057 · 8bd3057
1 parent 7a02c49
commit 8bd3057
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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 });