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));