Потеря данных в Materialized View ClickHouse

на тестовом контуре (2 шарда, 2 реплики) есть исходная таблица (Distributed + ReplicatedMergeTree) и Materialized View, который через оператор TО отправляет в результирующую таблицу (Distributed + ReplicatedMergeTree) выборочные данные. При ручном тестировании SELECT отрабатывает корректно, но при нагрузочном тестировании (данные идут с Kafka) в результирующую таблицу в среднем записывается в 4-5 раз меньше, чем выбирается тем же селектом из исходной таблицы. В чем может быть причина?