Uploaded image for project: 'Kafka Connector'
  1. Kafka Connector
  2. KAFKA-216

Source task should fail when not able to resume change stream

    XMLWordPrintableJSON

Details

    • Icon: New Feature New Feature
    • Resolution: Gone away
    • Icon: Major - P3 Major - P3
    • None
    • None
    • None
    • None

    Description

      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.

      Attachments

        Activity

          People

            ross@mongodb.com Ross Lawley
            nigel@nigelliang.com Nigel Liang
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: