diff --git a/function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java b/function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java
index 4a5ab03..18fb618 100644
--- a/function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java
+++ b/function-based-stream-app-samples/couchbase-stream-applications/couchbase-consumer/src/test/java/io/spring/example/couchbase/consumer/CouchbaseConsumerTests.java
@@ -81,8 +81,8 @@ public class CouchbaseConsumerTests {
 				"couchbase.consumer.keyExpression=payload.email")
 				.run(context -> {
 					CouchbaseConsumerProperties properties = context.getBean(CouchbaseConsumerProperties.class);
-					Cluster cluster = context.getBean(Cluster.class);
 					String bucketName = properties.getBucketExpression().getValue(String.class);
+					Cluster cluster = context.getBean(Cluster.class);
 					Function<Flux<Message<?>>, Flux<MutationResult>> couchbaseConsumerFunction = context
 							.getBean("couchbaseConsumerFunction", Function.class);
 					StepVerifier.create(couchbaseConsumerFunction