The Go implementation of the Couchbase to Elasticsearch with DCP. - View it on GitHub