update kafkaPublishTimestamp field

Author: hernandezc1

broker/setup_broker/lsst/templates/ps_lsst_add_top_level_fields_smt.yaml

@@ -14,7 +14,7 @@
         if (attrs.healpix19) newFields.healpix19 = attrs.healpix19.toString();
         if (attrs.healpix29) newFields.healpix29 = attrs.healpix29.toString();
         if (attrs["kafka.timestamp"]) {
-          newFields.kafkaPublishTimestamp = (Number(attrs["kafka.timestamp"])).toString();
+          newFields.kafkaPublishTimestamp = attrs["kafka.timestamp"].toString();
         }
 
         // Define the data as a set of key-value pairs to be added to the JSON payload

broker/setup_broker/lsst/templates/ps_lsst_flatten_schema_smt.yaml

@@ -17,7 +17,7 @@
           diaSourceId: attrs.diaSource_diaSourceId ? attrs.diaSource_diaSourceId.toString() : null,
           diaObjectId: attrs.diaObject_diaObjectId ? attrs.diaObject_diaObjectId.toString() : null,
           ssObjectId: attrs.ssSource_ssObjectId ? attrs.ssSource_ssObjectId.toString() : null,
-          kafkaPublishTimestamp: attrs["kafka.timestamp"] ? attrs["kafka.timestamp"].toString() : null
+          kafkaPublishTimestamp: attrs["kafka.timestamp"] ? attrs["kafka.timestamp"] * 1000 : null
         };
 
         // Return the flattened message
@@ -26,4 +26,4 @@
           attributes: message.attributes
         };
       }
-  functionName: flattenValueAddedAlert
+    functionName: flattenValueAddedAlert