(camel-kafka-connector) branch main updated: chore: use CouchStore backend for Couchbase 8.0.0 compatibility

[fmariani]

This is an automated email from the ASF dual-hosted git repository.

fmariani pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git


The following commit(s) were added to refs/heads/main by this push:
     new 41884c2bb7 chore: use CouchStore backend for Couchbase 8.0.0 
compatibility
41884c2bb7 is described below

commit 41884c2bb72af51be034177758c485167ef7fc5a
Author: Croway <federico.mariani.1...@gmail.com>
AuthorDate: Tue Apr 7 15:09:31 2026 +0200

    chore: use CouchStore backend for Couchbase 8.0.0 compatibility
---
 .../camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java
 
b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java
index 4fff797ea4..a43019d3e3 100644
--- 
a/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java
+++ 
b/tests/itests-couchbase/src/test/java/org/apache/camel/kafkaconnector/couchbase/sink/CamelSinkCouchbaseITCase.java
@@ -30,6 +30,7 @@ import com.couchbase.client.core.service.ServiceType;
 import com.couchbase.client.java.Cluster;
 import com.couchbase.client.java.json.JsonObject;
 import com.couchbase.client.java.manager.bucket.BucketSettings;
+import com.couchbase.client.java.manager.bucket.StorageBackend;
 import com.couchbase.client.java.query.QueryResult;
 import org.apache.camel.kafkaconnector.CamelSinkTask;
 import org.apache.camel.kafkaconnector.common.ConnectorPropertyFactory;
@@ -109,7 +110,7 @@ public class CamelSinkCouchbaseITCase extends 
CamelSinkTestSupport {
 
         LOG.debug("Creating a new bucket named {}", bucketName);
 
-        cluster.buckets().createBucket(BucketSettings.create(bucketName));
+        
cluster.buckets().createBucket(BucketSettings.create(bucketName).storageBackend(StorageBackend.COUCHSTORE));
         PingResult pingResult = cluster.bucket(bucketName).ping();
         pingResult.endpoints().entrySet().forEach(this::checkEndpoints);