Details
-
New Feature
-
Resolution: Gone away
-
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.