Dm983 timestamp as start time
Created by: michele-brambilla
Description of work
This PR closes ticket 983. If the timestamp is not specified in the command uses the timestamp of the Kafka message.
KafkaW::Msg
has now a new time() method that returns the timestamp of the message.
Acceptance Criteria
- Events must be written from and until the specified times
- If no time is specified start time must be the Kafka message timestamp
- If the Kafka message timestamp is empty start time must be the time at with the message has been received
- If no stop time is specified the file must be closed as the message arrives
Unit Tests
- Make sure that start and stop command use the values defined in the command
Code Review (To be filled in by the reviewer only)
-
Is the code of an acceptable quality? -
Do the changes function as described and is it robust?
Nominate for Group Code Review (Anyone can nominate it)
Indicate if you think the code should be reviewed in a Thursday code review session.
-
Recommend for group code review
Also, nominate it on the code_review Slack channel (does someone want to automate this?).