Permissions on free trial version of cappella

hey folks,

Is there any differences in granting priviledges for users using free trial version of cappella?

because I couldn’t see any role like “data dcp reader” . I could not connect my dcp client to cappella , and I doubt priviledges could be the reason .
I have granted read/writer permission to the database credential.

I get this error randomly while trying to connect to cluster via DCP.

code

 private static final String capellaCaCert = "-----BEGIN CERTIFICATE-----\n" +
            "MIIDFTCCAf2gAwIBAgIRANLVkgOvtaXiQJi0V6qeNtswDQYJKoZIhvcNAQELBQAw\n" +
            "JDESMBAGA1UECgwJQ291Y2hiYXNlMQ4wDAYDVQQLDAVDbG91ZDAeFw0xOTEyMDYy\n" +
            "MjEyNTlaFw0yOTEyMDYyMzEyNTlaMCQxEjAQBgNVBAoMCUNvdWNoYmFzZTEOMAwG\n" +
            "A1UECwwFQ2xvdWQwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQCfvOIi\n" +
            "enG4Dp+hJu9asdxEMRmH70hDyMXv5ZjBhbo39a42QwR59y/rC/sahLLQuNwqif85\n" +
            "Fod1DkqgO6Ng3vecSAwyYVkj5NKdycQu5tzsZkghlpSDAyI0xlIPSQjoORA/pCOU\n" +
            "WOpymA9dOjC1bo6rDyw0yWP2nFAI/KA4Z806XeqLREuB7292UnSsgFs4/5lqeil6\n" +
            "rL3ooAw/i0uxr/TQSaxi1l8t4iMt4/gU+W52+8Yol0JbXBTFX6itg62ppb/Eugmn\n" +
            "mQRMgL67ccZs7cJ9/A0wlXencX2ohZQOR3mtknfol3FH4+glQFn27Q4xBCzVkY9j\n" +
            "KQ20T1LgmGSngBInAgMBAAGjQjBAMA8GA1UdEwEB/wQFMAMBAf8wHQYDVR0OBBYE\n" +
            "FJQOBPvrkU2In1Sjoxt97Xy8+cKNMA4GA1UdDwEB/wQEAwIBhjANBgkqhkiG9w0B\n" +
            "AQsFAAOCAQEARgM6XwcXPLSpFdSf0w8PtpNGehmdWijPM3wHb7WZiS47iNen3oq8\n" +
            "m2mm6V3Z57wbboPpfI+VEzbhiDcFfVnK1CXMC0tkF3fnOG1BDDvwt4jU95vBiNjY\n" +
            "xdzlTP/Z+qr0cnVbGBSZ+fbXstSiRaaAVcqQyv3BRvBadKBkCyPwo+7svQnScQ5P\n" +
            "Js7HEHKVms5tZTgKIw1fbmgR2XHleah1AcANB+MAPBCcTgqurqr5G7W2aPSBLLGA\n" +
            "fRIiVzm7VFLc7kWbp7ENH39HVG6TZzKnfl9zJYeiklo5vQQhGSMhzBsO70z4RRzi\n" +
            "DPFAN/4qZAgD5q3AFNIq2WWADFQGSwVJhg==\n" +
            "-----END CERTIFICATE-----";
    public static void main( String[] args ) throws InterruptedException {

        Client client = Client.builder()
                .securityConfig(SecurityConfig.builder()
                        .enableTls(true)
                        .trustCertificates(SecurityConfig.decodeCertificates(
                                singletonList(capellaCaCert))
                        )
                )
                .seedNodes("aisgscfvptu1bftz.s9ptsvomaiatw6q9.cloud.couchbase.com")
                .credentials("admin6","Saibaba@09")
                .collectionsAware(true)
                .bucket("travel-sample")
                .collectionNames("inventory.airline")
                .flowControl(64 *1024 * 1024)
                .bootstrapTimeout(Duration.parse("PT10S"))
                .build();


        client.listener(new DatabaseChangeListener() {
            @Override
            public void onFailure(StreamFailure streamFailure) {
                System.out.println("mw");
            }

            @Override
            public void onMutation(Mutation mutation) {
                System.out.println("m");
            }
        }, FlowControlMode.AUTOMATIC);

        client.connect().block(Duration.parse("PT10S"));
        client.initializeState(StreamFrom.NOW, StreamTo.INFINITY).block(Duration.parse("PT10S"));
       int a =  client.numPartitions();
        client.startStreaming().block(Duration.parse("PT10S"));
    }
}


Hi Karthikeyan,

Since this response looks like a continuation of your conversation with our engineering team. I’ll link your SLF4J logs to the previous thread you created so the engineering team can look at it. Thank you.

1 Like