The Couchbase Kafka connector is a plug-in for the Kafka Connect framework. It provides source and sink components.

      The source connector streams documents from Couchbase Server using the high-performance Database Change Protocol (DCP) and publishes the latest version of each document to a Kafka topic in near real-time.

      The sink connector subscribes to Kafka topics and writes the messages to Couchbase Server.

      Delivery Guarantees

      Refer to the Delivery Guarantees page for a description of important limitations.


      Refer to the Compatibility page for information on compatible versions of Kafka and Couchbase Server.


      Couchbase welcomes community contributions to the Kafka connector. The Kafka Connector source code is available on GitHub.