Нет данных CDC в бинарных журналах Cassandra (CDC_RAW)JAVA

Программисты JAVA общаются здесь
Ответить Пред. темаСлед. тема
Anonymous
 Нет данных CDC в бинарных журналах Cassandra (CDC_RAW)

Сообщение Anonymous »

Я столкнулся с проблемой при использовании CDC в Cassandra и нуждается в вашей помощи, чтобы разрешить ее. CDC включен, и я вижу, что бинарные журналы создаются в каталоге CDC_RAW. Тем не менее, я заметил, что модификация данных (вставить новые записи, обновлять существующие или удалять записи) в этой таблице не отображаются в журналах CDC_RAW. То есть журналы остаются пустыми. < /P>

Для чтения двоичных журналов 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' };
4 создал таблицу demo.my_table_cdc_text

Код: Выделить всё

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;
5 Добавлены данные в таблицу demo.my_table_cdc_text (350 строк)

Код: Выделить всё

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;
p.s : я также попробовал эти параметры и команды:
  • Изменение параметра log_segment_size for 32mib на 1mib ;


Подробнее здесь: https://stackoverflow.com/questions/796 ... gs-cdc-raw
Реклама
Ответить Пред. темаСлед. тема

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

  • Похожие темы
    Ответы
    Просмотры
    Последнее сообщение

Вернуться в «JAVA»