Scylla CDC Example

CDC example

docker run --name some-scylla-night -d scylladb/scylla-nightly --experimental 1
docker exec -it some-scylla-night cqlsh

cqlsh>

CREATE KEYSPACE ks WITH replication = {'class': 'SimpleStrategy', 'replication_factor': '1'}  AND durable_writes = true;
CREATE TABLE ks.t (pk int, ck int, v int, PRIMARY KEY (pk, ck, v)) WITH cdc = {'enabled':true};
INSERT INTO ks.t (pk,ck,v) VALUES (1,2,3);
INSERT INTO ks.t (pk,ck,v) VALUES (1,2,4);

select * from ks.t_scylla_cdc_log ;

 cdc$stream_id                      | cdc$time                             | cdc$batch_seq_no | cdc$deleted_ck | cdc$deleted_pk | cdc$deleted_v | cdc$operation | cdc$ttl | ck | pk | v
------------------------------------+--------------------------------------+------------------+----------------+----------------+---------------+---------------+---------+----+----+---
 0x97a177ea890084b495c6e57c8a5dd1fd | 6abd2cbe-6f78-11ea-2069-c89fee9d77b2 |                0 |           null |           null |          null |             2 |    null |  2 |  1 | 3
 0x97a177ea890084b495c6e57c8a5dd1fd | 6dd10312-6f78-11ea-df03-ce304c8c88f1 |                0 |           null |           null |          null |             2 |    null |  2 |  1 | 4