add log

Enterprise-CMCS · Nov 26, 2024 · c4d5e23 · c4d5e23
1 parent b350788
commit c4d5e23
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/lib/lambda/sinkMain.ts b/lib/lambda/sinkMain.ts
@@ -30,9 +30,6 @@ export const handler: Handler<KafkaEvent> = async (event) => {
           logError({ type: ErrorType.BADTOPIC });
           throw new Error();
         case "aws.onemac.migration.cdc":
-          console.log("IN THIS TOPIC?");
-          console.log(opensearch.main.transforms, "TRANSFORMSSS");
-          console.log(topicPartition, "TOPIC PARTITION");
           await processAndIndex({
             kafkaRecords: event.records[topicPartition],
             index,
@@ -101,6 +98,8 @@ const processAndIndex = async ({
           }
 
           if (record.adminChangeType === "update-values") {
+            console.log("IN UPDATE VALUES");
+            console.log(record, "RECORD TO CHANGE");
             docs.push(record);
           }
         }