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.
Hi,
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: https://github.com/couchbase/couchbase-kafka-connector/