Couchbase Kafka Connector

Kafka Connect plugin that uses DCP (Database Change Protocol) to stream every mutation, deletion, and expiration from Couchbase to Kafka (Source) or write Kafka records to Couchbase (Sink).

Installation

# Confluent Hub
confluent-hub install couchbase/kafka-connect-couchbase:4.2.6

# Or add ZIP to plugin.path in connect-*.properties

Required RBAC: Source → data_dcp_reader on bucket; Sink → data_writer on collection.

Source Connector — Couchbase → Kafka