Kafka message header timestamp should be set
Created by: matthew-d-jones
Check what the C++ forwarder does, but I'm fairly sure that the Kafka message header timestamp should be set to the same as the payload timestamp.
This is done by providing the timestamp to the Producer.produce()
call. Note that the producer requires it in milliseconds, not the nanoseconds of the payload timestamp.
https://github.com/ess-dmsc/forwarder/blob/e8283297f92c3f2d2a379f92d5685ae32bb6b053/forwarder/kafka/kafka_producer.py#L28