diff --git a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorConfig.java b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorConfig.java index 38b4c11d1..2730000cc 100644 --- a/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorConfig.java +++ b/debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorConfig.java @@ -300,7 +300,7 @@ public static SnapshotMode parse(String value, String defaultValue) { .withImportance(Importance.MEDIUM) .withDescription("The maximum number of documents that should be loaded into memory while performing a snapshot") .withDefault(0) - .withValidation(Field::isPositiveInteger); + .withValidation(Field::isNonNegativeInteger); protected static final Field TASK_ID = Field.create("mongodb.task.id") .withDescription("Internal use only")