update kafkaPublishTimestamp field

hernandezc1 · hernandezc1 · commit 7bc02c601459 · 2025-10-07T09:17:49.000-04:00
diff --git a/broker/setup_broker/lsst/templates/ps_lsst_add_top_level_fields_smt.yaml b/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 = attrs["kafka.timestamp"].toString();
+          newFields.kafkaPublishTimestamp = attrs["kafka.timestamp"] * 1000;
         }
 
         // Define the data as a set of key-value pairs to be added to the JSON payload

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@`
`14`	`14`	`if (attrs.healpix19) newFields.healpix19 = attrs.healpix19.toString();`
`15`	`15`	`if (attrs.healpix29) newFields.healpix29 = attrs.healpix29.toString();`
`16`	`16`	`if (attrs["kafka.timestamp"]) {`
`17`		`- newFields.kafkaPublishTimestamp = attrs["kafka.timestamp"].toString();`
	`17`	`+ newFields.kafkaPublishTimestamp = attrs["kafka.timestamp"] * 1000;`
`18`	`18`	`}`
`19`	`19`
`20`	`20`	`// Define the data as a set of key-value pairs to be added to the JSON payload`