Я пытаюсь запросить 30-секундный оконный магазин следующим образом:
ReadOnlyWindowStore<String, Long> queryableStore
...
KeyValueIterator<Windowed<String>, Long> iter = queryableStore.fetch("A", "E", now - (60 * 1000 * 5), now)
Есть ли сценарий, при котором я получаю дублирующиеся окна на выходе? Я ожидал, что это вернет самое большее 50 уникальных окон (5 ключей x 10 окон). Я наблюдаю, что у меня больше 50 окон, и некоторые из них дублируются. Дубликаты встречаются по направлению к последним записям в итераторе. Рекомендуется ли в этом случае вручную удалять дубликаты?
Заранее спасибо!
Спасибо. Похоже, я столкнулся с той же проблемой. Когда выйдет 2.0.1? Видимо, это первая GA с этим исправлением?
Плана выпуска 2.0.1 пока нет - 2.1.0 запланирован на конец октября. Cf cwiki.apache.org/confluence/display/KAFKA/Future+release+pla n
Может быть, вы столкнулись с этой ошибкой: issues.apache.org/jira/browse/KAFKA-7158?