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; -- Сверяем количество записей с таблицей в источнике
                  
                  
                  
                  
                  
                  При выполнении всех команд, все равно пропадает часть записей, ничем не отличимых от других. Есть у кого-то идеи в чем может быть дело?
                  
                  
                
Снимаем снепшот таблицы в топик?
Данные попадают в Кафку через кафка коннект. В этом пункте я посылаю сигнал в сигнальную таблицу, что бы снять снапшот.
Обсуждают сегодня