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/