Populate messageTimestamp in the PipelineInputMessage
The following discussion from !12 (merged) should be addressed:
-
@martypitt started a discussion: (+2 comments) Since I wrote that TODO in the original example, I think that the publisher time isn't in the headers. However, I'm pretty certain it'll be in the avro wrapper (or if not, we should ask for it to be).
Note: either from Avro message or from Kafka header (if present)