true. Таблица distributed, 2 шарда. Данные поставляются из постгреса через кафку.
Вот условный план работ:
alter table Replicated_table_test on cluster dlstorage update deleted = true where true; -- удаляем записи
select count(*) from Distributed_table_test where deleted = false; -- Проверяем что они удалились
alter table Replicated_table_test on cluster dlstorage modify setting replicated_deduplication_window_seconds = 0; --Выключаем дедупликацию
--снимаем снэпшот с таблицы в топик
select count(*) from Distributed_table_test final where deleted = false; -- Сверяем количество записей с таблицей в источнике
При выполнении всех команд, все равно пропадает часть записей, ничем не отличимых от других. Есть у кого-то идеи в чем может быть дело?
Снимаем снепшот таблицы в топик?
Данные попадают в Кафку через кафка коннект. В этом пункте я посылаю сигнал в сигнальную таблицу, что бы снять снапшот.
Обсуждают сегодня