https://github.com/microsoft/kafka-connect-cosmosdb/blob/84a32c063c05c9e982a3fc73e6ae89831257a00a/src/main/java/com/azure/cosmos/kafka/connect/source/CosmosDBSourceConnector.java#L59 If user gives maxTasks less than num containers , then few container will never be read . So we can have validation in config to avoid that case.