-
Type: Task
-
Resolution: Fixed
-
Priority: Major - P3
-
Affects Version/s: None
-
Component/s: None
-
None
-
Atlas Streams
-
Fully Compatible
-
Sprint 65
- Rename the existing minEventTimestampMs and maxEventTimestampMs fields in StreamDocument to instead be minDocTimestampMs and maxDocTimestampMs. These will hold the timestamp of an event and will either be the processingTime timestamp or the eventTime timestamp.
- Make watermarks work - rename the eventTimeWatermarkMs field in the watermark control message to watermarkTimestampMs and populate it with the right timestamp.
- has to be done before
-
SERVER-98430 Processing time window impl for change stream source operator
- Closed
-
SERVER-98431 Add support for KafkaConsumerOperator for processingTime windows and add checkpointing tests
- Investigating