Source task should fail when not able to resume change stream

XMLWordPrintableJSON

    • Type: New Feature
    • Resolution: Gone away
    • Priority: Major - P3
    • None
    • Affects Version/s: None
    • Component/s: None
    • None
    • None
    • None
    • None
    • None
    • None
    • None
    • None

      The current implementation of `MongoSourceTask::tryCreateCursor` ends with

      if (resumeTokenNotFound(e)) {
            throw new ConnectException(
                "ResumeToken not found. Cannot create a change stream cursor", e);
          }
        }
        return null;
      }
      

      In the event that the cursor was not able to be created for a reason other than the "resume token not found" error, the connector does not fail and instead starts and processes no messages.

            Assignee:
            Ross Lawley
            Reporter:
            Nigel Liang
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

              Created:
              Updated:
              Resolved: