I have created flink (java ) to stream data from kafka topic to couchbase
In my flink’s logic, I use several N1QL query before upsert to couchbase
I have created GSI index and have tested each query only around 30ms
I have loaded 1,6 mio data to kafka to process to couchbase
It takes around 200 ops which is too long to process whole data
How can I increase the performance?
FYI I use Java SDK 2.7.13 and Couchbase 6.5.1