Uploaded image for project: 'Core Server'
  1. Core Server
  2. SERVER-98431

Add support for KafkaConsumerOperator for processingTime windows and add checkpointing tests

XMLWordPrintableJSON

    • Type: Icon: Task Task
    • Resolution: Unresolved
    • Priority: Icon: Major - P3 Major - P3
    • None
    • Affects Version/s: None
    • Component/s: None
    • None
    • Atlas Streams
    • Sprint 66, Sprint 67

      • The changes required here will be minimal after having added support for the ChangeStreamOperator. In the KafkaConsumerOperator case, add additional tests to ensure that the per partition watermark is also being updated correctly with processingTime timestamps
      • Add tests with checkpoints in the middle

            Assignee:
            jada.lilleboe@mongodb.com Jada Lilleboe
            Reporter:
            mayuresh.kulkarni@mongodb.com Mayuresh Kulkarni
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

              Created:
              Updated: