Kafka Connector 2.0
The Kafka connector provides functionality to stream, filter, and transform events from Couchbase Server to Kafka.
The Couchbase Kafka connector enables you to send data events from a Couchbase Server cluster to a Kafka cluster by using the Couchbase database change protocol (DCP).
The Kafka Connector includes the following components:
Java client (source code)
Developer guide and reference documentation
Because the Kafka connector relies heavily on DCP, it is only compatible with Couchbase Server 3.0 and later.
Couchbase welcomes community contributions to the Kafka connector. The Kafka Connector source code is available on GitHub.