решена - она делает не то, что вам надо.
у вас одинаковые параметры ofSizeAndGrace, т.о. каждое сообщение попадать будет лишь один раз и в одно из окон.
дубли могут быть лишь тогда, когда одинаковый ключ попадает в разные окна.
вывод - может быть у вас слишком маленькое окно?
Видимо я не достаточно ясно отразил проблему. Попробую еще раз: оконная функция отрабатывает нормально, пакеты в аргрегационном топике собираются нормально. Но в этом топике присутствуют "рабочие" (наполняющиеся) версии пакетов вместе с финальными. Эта проблема касается только тех из пакетов, которые формировались последними. Со "старыми" такой проблемы нет. Проблема ожидаемая, но смущает, что она "живет" дольше таймаута жизни активного сегмента. Вот как это победить?
кстати, а можете поделиться кодом после аггрегации?
Обсуждают сегодня