From bf219f12f269733665db3064a733c74f1f9694b2 Mon Sep 17 00:00:00 2001 From: Jayasudha Sundaram Date: Fri, 14 Mar 2025 17:35:07 -0400 Subject: [PATCH] fix for kafka sync error and added missing column --- .../investigation/repository/model/dto/Treatment.java | 3 +++ .../investigation/service/InvestigationService.java | 3 +-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/repository/model/dto/Treatment.java b/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/repository/model/dto/Treatment.java index 56f24d57..9aac1a7d 100644 --- a/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/repository/model/dto/Treatment.java +++ b/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/repository/model/dto/Treatment.java @@ -89,4 +89,7 @@ public class Treatment { @Column(name = "version_ctrl_nbr") private String versionControlNumber; + + @Column(name = "morbidity_uid") + private String morbidityUid; } diff --git a/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/service/InvestigationService.java b/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/service/InvestigationService.java index 8d79c186..253b303c 100644 --- a/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/service/InvestigationService.java +++ b/investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/service/InvestigationService.java @@ -285,8 +285,7 @@ private void processTreatment(String value) { TreatmentReportingKey treatmentReportingKey = new TreatmentReportingKey(treatment.getTreatmentUid()); String jsonKey = jsonGenerator.generateStringJson(treatmentReportingKey); - String jsonValue = jsonGenerator.generateStringJson(treatment); - + String jsonValue = jsonGenerator.generateStringJson(treatment,"treatment_uid"); kafkaTemplate.send(treatmentOutputTopicName, jsonKey, jsonValue) .whenComplete((res, e) -> logger.info("Treatment data (uid={}) sent to {}", treatment.getTreatmentUid(), treatmentOutputTopicName));