Change data capture (CDC) Beta

    If you haven’t installed YugabyteDB yet, do so first by following the Quick Start guide.

    A JRE (or JDK), for Java 8 or later, is installed. JDK and JRE installers for Linux, macOS, and Windows can be downloaded from , AdoptOpenJDK, or .

    Add a table, named users, to the default yugabyte database.

    1. CREATE TABLE products(
    2.   id         bigserial PRIMARY KEY,
    3.   created_at timestamp,
    4.   category   text,
    5.   ean        text,
    6.   price      float,
    7.   quantity   int default(5000),
    8.   rating     float,
    9.   title      text,
    10.   vendor     text
    11. );

    Download the CDC Connector JAR file (yb-cdc-connector.jar).

    1. java -jar yb-cdc-connector.jar \
    2. --table_name yugabyte.products \
    3. --log_only

    The example above uses the following parameters:

    • —table_name — Specifies the namespace and table, where namespace is the database (YSQL) or keyspace (YCQL).
    • —master_addrs — Specifies the IP addresses for all of the YB-Master servers that are producing or consuming. Default value is 127.0.0.1:7100. If you are using a 3-node local cluster, then you need to specify a comma-delimited list of the addresses for all of your YB-Master servers.
    • —log_only: Flag to restrict logging only to the console (stdout).

    In another terminal shell, write some values to the table and observe the values on your stdout output stream.

    2. key {
    3.   key: "id"
    4.   value {
    5.     int64_value: 14
    6.   }
    7. }
    8. changes {
    9.   key: "created_at"
    10.   value {
    11.     int64_value: 568046516870000
    12.   }
    13. }
    14. changes {
    15.   key: "category"
    16.   value {
    17.     string_value: "Widget"
    18.   }
    19. }
    20. changes {
    21.   key: "ean"
    22.   value {
    23.     string_value: "8833419218504"
    24.   }
    25. }
    26. changes {
    28.     double_value: 25.09876359271891
    29.   }
    30. }
    31. changes {
    32.   key: "quantity"
    33.   value {
    34.     int32_value: 5000
    35.   }
    36. }
    37. changes {
    38.   key: "rating"
    39.   value {
    40.     double_value: 4.0
    41.   }
    42. }
    43. changes {
    44.   key: "title"
    45.   value {
    46.     string_value: "Awesome Concrete Shoes"
    47.   }
    48. }
    49. changes {
    50.   key: "vendor"
    51.   value {
    52.     string_value: "McClure-Lockman"