import com.couchbase.client.java.Bucket; import com.couchbase.client.java.CouchbaseCluster; public class CouchbaseSyncReplicationExample { public static void main(String[] args) { CouchbaseCluster cluster = CouchbaseCluster.create("localhost"); Bucket sourceBucket = cluster.openBucket("source_bucket"); Bucket targetBucket = cluster.openBucket("target_bucket"); sourceBucket.startReplicationWith(targetBucket); cluster.disconnect(); } }