fix kafka

egovernments · Jul 25, 2024 · ae6d57e · ae6d57e
1 parent 3ab35d4
commit ae6d57e
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/utilities/project-factory/src/server/utils/campaignMappingUtils.ts b/utilities/project-factory/src/server/utils/campaignMappingUtils.ts
@@ -427,7 +427,10 @@ export async function processMapping(mappingObject: any) {
         }
         logger.info("Mapping completed successfully for campaign: " + mappingObject?.CampaignDetails?.id);
         mappingObject.CampaignDetails.status = campaignStatuses.inprogress
-        produceModifiedMessages(mappingObject, config?.kafka?.KAFKA_UPDATE_PROJECT_CAMPAIGN_DETAILS_TOPIC)
+        const produceMessage: any = {
+            CampaignDetails: mappingObject?.CampaignDetails
+        }
+        produceModifiedMessages(produceMessage, config?.kafka?.KAFKA_UPDATE_PROJECT_CAMPAIGN_DETAILS_TOPIC)
         await persistTrack(mappingObject?.CampaignDetails?.id, processTrackTypes.campaignCreation, processTrackStatuses.completed)
     } catch (error) {
         logger.error("Error in campaign mapping: " + error);