This is an example Couchbase DCP consumer and is meant to serve as the basis for integrating Couchbase with any streaming systems, such as Storm, or implementing trigger-based scenarios, such as Pub/Sub. Based on the excellent couchbase-kafka integration demo by Sergey Avseyev.
branor / couchbase-dcp-consumer Goto Github PK
View Code? Open in Web Editor NEWinitial commit