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"));
}
}