Для чтения двоичных журналов CDC (CDC_RAW) я полагаюсь на предварительно построенный Cassandra 4.1.8 в Docker
2 Установите переменные в файле /etc/cassandra/cassandra.yaml
cdc_enabled: true
cdc_raw_directory: /var/lib/cassandra/cdc_raw
commitolog_directory:/var/lib/cassandra/commitolog
cdc_total_space: 4096mib
cdc_free_space_sheck_interval: /> < /blockquote>
3 создал демоверсию Keyspace < /code> < /p>
Код: Выделить всё
CREATE KEYSPACE demo WITH REPLICATION = { 'class' : 'org.apache.cassandra.locator.SimpleStrategy', 'replication_factor': '3' };
Код: Выделить всё
CREATE TABLE demo.my_table_cdc_text(
id int,
code text,
first_name text,
last_name text,
email text,
PRIMARY KEY(id, code)
)
WITH cdc=true;
Код: Выделить всё
BEGIN batch
INSERT INTO demo.my_table_cdc_text (id, code, email, first_name, last_name) VALUES(769, 'brown fox jumps over t', 'Joelle.Stuart.11@yahoo.in', 'Abraham', 'Douglas');
INSERT INTO demo.my_table_cdc_text (id, code, email, first_name, last_name) VALUES(769, 'dogThe quick brown fox jumps ove', 'Calvin.Haines.02@hetnet.nl', 'Oscar', 'Jeremy');
INSERT INTO demo.my_table_cdc_text (id, code, email, first_name, last_name) VALUES(769, 'dogThe quick brown fox jumps over t', 'Mercedes.Pippen.46@yahoo.es', 'Maggie', 'Roberta');
.........
INSERT INTO demo.my_table_cdc_text (id, code, email, first_name, last_name) VALUES(769, 'fox jumps over', 'Teresa.Plumb.84@laposte.net', 'Ida', 'Tamara');
INSERT INTO demo.my_table_cdc_text (id, code, email, first_name, last_name) VALUES(769, 'fox jumps over the lazy dogThe quick bro', 'Hodierna.Nicol.73@terra.com.br', 'Rich', 'Beatrice');
apply batch;
- Изменение параметра log_segment_size for 32mib на 1mib ;
Подробнее здесь: https://stackoverflow.com/questions/796 ... gs-cdc-raw