Cluster cluster = Cluster.connect("couchbase://localhost"); Bucket bucket = cluster.bucket("your_bucket_name"); JsonObject document = JsonObject.create() .put("name", "John Doe") .put("age", 30) .put("email", "john.doe@example.com"); bucket.defaultCollection().upsert("document_id", document); cluster.disconnect();