-
Type: Task
-
Resolution: Unresolved
-
Priority: Major - P3
-
None
-
Affects Version/s: None
-
Component/s: None
-
None
-
Atlas Streams
- Need to create a mocked change stream consumer, similar to the FakeKafkaPartitionConsumer
- Add unit tests for a pipeline with change stream source and processing time windows and check that docs are being assigned to windows correctly
- Add unit tests to check that windows are closing as expected
- has to be done after
-
SERVER-98430 Processing time window impl for change stream source operator
- Closed