diff --git a/couchbase-log/src/main/java/org/apache/camel/example/MyRouteBuilder.java b/couchbase-log/src/main/java/org/apache/camel/example/MyRouteBuilder.java
index 91cec4b06..a828dd2bd 100644
--- a/couchbase-log/src/main/java/org/apache/camel/example/MyRouteBuilder.java
+++ b/couchbase-log/src/main/java/org/apache/camel/example/MyRouteBuilder.java
@@ -23,7 +23,7 @@ public class MyRouteBuilder extends RouteBuilder {
     @Override
     public void configure() throws Exception {
 
-        from("couchbase:http://{{couchbase.host}}:{{couchbase.port}}?bucket={{couchbase.bucket}}&username={{couchbase.username}}&password={{couchbase.password}}&consumerProcessedStrategy={{couchbase.consumerProcessedStrategy}}")
+        from("couchbase:http://{{couchbase.host}}:{{couchbase.port}}?bucket={{couchbase.bucket}}&username={{couchbase.username}}&password={{couchbase.password}}&consumerProcessedStrategy={{couchbase.consumerProcessedStrategy}}&useView=true&connectionString={{couchbase.connectionString}}")
           .to("log:info");
 
     }
diff --git a/couchbase-log/src/main/resources/application.properties b/couchbase-log/src/main/resources/application.properties
index d9fbad393..dd6f965b9 100644
--- a/couchbase-log/src/main/resources/application.properties
+++ b/couchbase-log/src/main/resources/application.properties
@@ -21,6 +21,7 @@ camel.main.name = LogCouchbase
 
 couchbase.host=localhost
 couchbase.port=8091
+couchbase.connectionString=couchbase://localhost:11210
 couchbase.username=admin
 couchbase.password=password
 couchbase.bucket=beer-sample
diff --git a/couchbase-log/src/test/java/org/apache/camel/example/CouchbaseTest.java b/couchbase-log/src/test/java/org/apache/camel/example/CouchbaseTest.java
index cf74a1c1d..8b320677b 100644
--- a/couchbase-log/src/test/java/org/apache/camel/example/CouchbaseTest.java
+++ b/couchbase-log/src/test/java/org/apache/camel/example/CouchbaseTest.java
@@ -26,6 +26,7 @@
 import com.couchbase.client.java.json.JsonObject;
 import com.couchbase.client.java.manager.bucket.BucketSettings;
 import com.couchbase.client.java.manager.bucket.BucketType;
+import com.couchbase.client.java.manager.bucket.StorageBackend;
 import com.couchbase.client.java.manager.view.DesignDocument;
 import com.couchbase.client.java.manager.view.View;
 import com.couchbase.client.java.view.DesignDocumentNamespace;
@@ -68,7 +69,7 @@ static void init() {
             )
         );
         CLUSTER.buckets().createBucket(
-                BucketSettings.create(BUCKET).bucketType(BucketType.COUCHBASE).flushEnabled(true));
+                BucketSettings.create(BUCKET).bucketType(BucketType.COUCHBASE).storageBackend(StorageBackend.COUCHSTORE).flushEnabled(true));
         CLUSTER.bucket(BUCKET).viewIndexes().upsertDesignDocument(designDoc, DesignDocumentNamespace.PRODUCTION);
     }
 
@@ -83,7 +84,9 @@ static void destroy() {
     @Override
     public void configureContext(CamelContextConfiguration camelContextConfiguration) {
         super.configureContext(camelContextConfiguration);
+        System.out.println("#### " + SERVICE.getConnectionString());
         Properties overridenProperties = asProperties(
+                "couchbase.connectionString", SERVICE.getConnectionString(),
                 "couchbase.host", SERVICE.hostname(),
                 "couchbase.port", Integer.toString(SERVICE.port()),
                 "couchbase.username", SERVICE.username(),