Please use the form below to provide your feedback. Because your feedback is valuable to us, the information you submit in this form is recorded in our issue tracking system (JIRA), which is publicly available. You can track the status of your feedback using the ticket number displayed in the dialog once you submit the form.

A newer version of this documentation is available.

View Latest

Introduction

    +
    The Kafka connector provides functionality to stream, filter, and transform events between Couchbase Server and Kafka.

    The Couchbase sink connector allows you to import data from Kafka topics into Couchbase Server.

    The Couchbase source connector allows you to export data from Couchbase Server to Kafka topics.

    Data is loaded efficiently and reliably using Couchbase’s internal replication protocol, DCP. Every change to or deletion of the document generates a replication event, which is then sent to the configured Kafka topic. When copying data from a bucket, the connector loads only new or modified documents.

    Compatibility

    Because the Kafka connector relies heavily on DCP, it is only compatible with Couchbase Server 3.0 and later.

    The Kafka connector implements the Kafka Connect plug-in standard.

    Contributing

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