Retrieving newly added or recently updated documents from the bucket

How can I set Observables to listen to different events from a bucket? So that whenever a new document added to the bucket or existing document updated I can read them and push it to the destination.

Note: Just getting started with couchbase.


Listening to mutation coming in to the Couchbase repository is more like a DCP use case. Unfortunately we don’t have a public API for that right now. You should take a look at our Kafka connector to get an idea: