---
title: "Debezium and CDC in YugabyteDB"
url: "https://docs.yugabyte.com/stable/integrations/cdc/debezium/"
---

# Debezium and CDC in YugabyteDB

Using Debezium for CDC in YugabyteDB.

Debezium is an open-source distributed platform used to capture the changes in a database. The [YugabyteDB gRPC Connector](/stable/additional-features/change-data-capture/using-yugabytedb-grpc-replication/ "YugabyteDB gRPC Connector") is based on the Debezium Connector, and captures row-level changes in a YugabyteDB database's schemas.

## Get the YugabyteDB gRPC Connector

Using Docker, you can get the connector from Quay:

```sh
docker pull quay.io/yugabyte/debezium-connector:latest
```

If you want to build the connector image yourself, follow the steps in the [README for debezium-connector-yugabytedb](https://github.com/yugabyte/debezium-connector-yugabytedb/blob/main/README.md "README for debezium-connector-yugabytedb").

## Run Debezium locally

Use the following steps to run change data capture (CDC) with Debezium on a local YugabyteDB cluster:

1. Start Zookeeper.
   
   ```sh
   docker run -it --rm --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:1.9
   ```
2. Start Kafka.
   
   ```sh
   docker run -it --rm --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kafka:1.9
   ```
3. Assign your computer's IP address to an environment variable.
   
   ```sh
   # macOS:
   export IP=$(ipconfig getifaddr en0)
   
   # Linux:
   export IP=$(hostname -i)
   ```
4. Start a cluster using yugabyted. Note that you need to run yugabyted with the IP of your machine; otherwise, it would consider localhost (which would be mapped to the docker host instead of your machine).
   
   ```sh
   ./bin/yugabyted start --advertise_address $IP
   ```
5. Connect using ysqlsh and create a table:
   
   ```sh
   ./bin/ysqlsh -h $IP
   ```
   
   ```sql
   create table test (id int primary key, name text, days_worked bigint);
   ```

### Create a database stream ID

[EA](/stable/releases/versioning/#feature-maturity) Create the stream using PostgreSQL replication slot commands and the `yb_grpc` plugin (v2026.1.2.0 and later):

```sql
SELECT * FROM pg_create_logical_replication_slot('my_grpc_slot', 'yb_grpc');
SELECT yb_stream_id FROM pg_replication_slots WHERE slot_name = 'my_grpc_slot';
```

Alternatively, use [yb-admin](/stable/admin/yb-admin#change-data-capture-cdc-commands "yb-admin") to create a stream ID:

```sh
./bin/yb-admin --master_addresses ${IP}:7100 create_change_data_stream ysql.yugabyte
```

Note

For v2026.1.2.0 and later, PostgreSQL replication slot syntax is recommended.

You should see output similar to the following:

```output
CDC Stream ID: d540f5e4890c4d3b812933cbfd703ed3
```

For details, see [Create a gRPC CDC stream](/stable/additional-features/change-data-capture/using-yugabytedb-grpc-replication/cdc-get-started/#create-a-grpc-cdc-stream "Create a gRPC CDC stream").

### Start Debezium

Launch the connector:

```sh
docker run -it --rm \
  --name connect -p 8083:8083 -e GROUP_ID=1 \
  -e CONFIG_STORAGE_TOPIC=my_connect_configs \
  -e OFFSET_STORAGE_TOPIC=my_connect_offsets \
  -e STATUS_STORAGE_TOPIC=my_connect_statuses \
  --link zookeeper:zookeeper --link kafka:kafka \
  quay.io/yugabyte/debezium-connector:latest
```

Deploy the configuration for the connector:

```bash
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" \
  localhost:8083/connectors/ \
  -d '{
  "name": "ybconnector",
  "config": {
    "connector.class": "io.debezium.connector.yugabytedb.YugabyteDBgRPCConnector",
    "database.hostname":"'$IP'",
    "database.port":"5433",
    "database.master.addresses": "'$IP':7100",
    "database.user": "yugabyte",
    "database.password": "yugabyte",
    "database.dbname" : "yugabyte",
    "database.server.name": "dbserver1",
    "table.include.list":"public.test",
    "database.streamid":"d540f5e4890c4d3b812933cbfd703ed3",
    "snapshot.mode":"never"
  }
}'
```

### Use SSL

If you have an SSL-enabled cluster, you need to provide the path to the root certificate in the `database.sslrootcert` configuration property.

Do the following:

1. Copy the certificate file to your Docker container (assuming that the file exists on the root directory of your machine):
   
   ```sh
   docker cp ~/root.crt connect:/kafka/
   ```
2. Deploy the connector configuration:
   
   ```sh
   curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" \
     localhost:8083/connectors/ \
     -d '{
     "name": "ybconnector",
     "config": {
       "connector.class": "io.debezium.connector.yugabytedb.YugabyteDBgRPCConnector",
       "database.hostname":"'$IP'",
       "database.port":"5433",
       "database.master.addresses": "'$IP':7100",
       "database.user": "yugabyte",
       "database.password": "yugabyte",
       "database.dbname" : "yugabyte",
       "database.server.name": "dbserver1",
       "table.include.list":"public.test",
       "database.streamid":"d540f5e4890c4d3b812933cbfd703ed3",
       "snapshot.mode":"never",
       "database.sslrootcert":"/kafka/root.crt"
     }
   }'
   ```

For a list of all the configuration options provided with the YugabyteDB gRPC Connector, see [Connector configuration properties](/stable/additional-features/change-data-capture/using-yugabytedb-grpc-replication/debezium-connector-yugabytedb/#connector-configuration-properties "Connector configuration properties").

TRUNCATE tables when CDC is enabled

By default, the YugabyteDB CDC implementation does not allow you to TRUNCATE a table while an active CDC stream is present on the namespace. To allow truncating tables while CDC is active, set the [enable\_truncate\_cdcsdk\_table](/stable/reference/configuration/yb-tserver/#enable-truncate-cdcsdk-table "enable_truncate_cdcsdk_table") flag to true.

### Start a Kafka Topic console consumer (optional)

```sh
docker run -it --rm --name consumer --link zookeeper:zookeeper --link kafka:kafka debezium/kafka:1.9 \
watch-topic -a dbserver1.public.test
```

## Other examples

To explore other examples on the usage of CDC, refer to [CDC examples](https://github.com/yugabyte/cdc-examples "CDC examples").