diff --git a/mongodbreactivestreams/src/main/java/site/ycsb/db/MongoDbReactiveStreamsClient.java b/mongodbreactivestreams/src/main/java/site/ycsb/db/MongoDbReactiveStreamsClient.java
index d6731c92..d2545afd 100644
--- a/mongodbreactivestreams/src/main/java/site/ycsb/db/MongoDbReactiveStreamsClient.java
+++ b/mongodbreactivestreams/src/main/java/site/ycsb/db/MongoDbReactiveStreamsClient.java
@@ -184,10 +184,10 @@ public class MongoDbReactiveStreamsClient extends DB {
       // Set is inserts are done as upserts. Defaults to false.
       useUpsert = this.getBooleanProperty("mongodb.upsert", DEFAULT_USE_UPSERT);
 
-      // Just use the standard connection format URL
-      // http://docs.mongodb.org/manual/reference/connection-string/
+      // check http://docs.mongodb.org/manual/reference/connection-string/
       // to configure the client.
       String url = this.getStringProperty("mongodb.url", "mongodb://localhost:27017/ycsb?w=1");
+      url = OptionsSupport.updateUrl(url, getProperties());
 
       ConnectionString connectionString = new ConnectionString(url);
       try {
@@ -213,7 +213,7 @@ public class MongoDbReactiveStreamsClient extends DB {
         LOGGER.error("Could not initialize MongoDB connection pool for Loader: "
             + e1.toString());
         e1.printStackTrace();
-        return;
+        System.exit(1);
       }
     }
   }