Fix for kafka sync error and added missing column (#257)

Author: jayasudhasundaram

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

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