Hi,
I am migrating Couchbase Java SDK from 2.x to 3.x. can someone please help me how to write logic of executing parameterized N1ql query in java SDK 3. Below is the reactive java code I written in SDK 2.0.
final Flux findResult = repository.getCouchbaseOperations()
.findByN1QL(N1qlQuery.parameterized(findQuery, queryParams), MyObject.class)
.doOnError(ex → LOG.error(“MSG=‘Find query failed’, errorMsg={}”, ex.getMessage()))
.retryWhen(retry.createRetryForN1qlQuery(retryConfig, LOG).build());