Updated startAfter support check

rozza · rozza · commit 3e324722f403 · 2020-04-08T11:40:08.000+01:00
KAFKA-95
diff --git a/src/main/java/com/mongodb/kafka/connect/source/MongoSourceTask.java b/src/main/java/com/mongodb/kafka/connect/source/MongoSourceTask.java
@@ -245,7 +245,7 @@ private MongoCursor<BsonDocument> tryCreateCursor(final MongoSourceConfig source
                 if (e.getErrorCode() == 260) {
                     invalidatedCursor = true;
                     return tryCreateCursor(sourceConfig, mongoClient, null);
-                } else if (e.getErrorCode() == 40415 && e.getErrorMessage().contains("startAfter")) {
+                } else if ((e.getErrorCode() == 9 || e.getErrorCode() == 40415) && e.getErrorMessage().contains("startAfter")) {
                     supportsStartAfter = false;
                     return tryCreateCursor(sourceConfig, mongoClient, resumeToken);
                 }

Original file line number	Diff line number	Diff line change
`@@ -245,7 +245,7 @@ private MongoCursor<BsonDocument> tryCreateCursor(final MongoSourceConfig source`
`245`	`245`	`if (e.getErrorCode() == 260) {`
`246`	`246`	`invalidatedCursor = true;`
`247`	`247`	`return tryCreateCursor(sourceConfig, mongoClient, null);`
`248`		`- } else if (e.getErrorCode() == 40415 && e.getErrorMessage().contains("startAfter")) {`
	`248`	`+ } else if ((e.getErrorCode() == 9 \|\| e.getErrorCode() == 40415) && e.getErrorMessage().contains("startAfter")) {`
`249`	`249`	`supportsStartAfter = false;`
`250`	`250`	`return tryCreateCursor(sourceConfig, mongoClient, resumeToken);`
`251`	`251`	`}`