Как выбрать тип временной семантики при работе с падающими окнами? - PullRequest
Новая
       13

Как выбрать тип временной семантики при работе с падающими окнами?

1 голос
/ 13 апреля 2019

Я работаю над управлением окнами потоков kafka, в частности, окнами для моего варианта использования. 

TimeWindowedKStream<String, Blob> windowedStreams = groupedStreams
                .windowedBy(TimeWindows.of(TimeUnit.MINUTES.toMillis(5)));

это падающее окно на 5 минут для каждого ключа записи и продвижение на 5 минут. Для моего случая использования я не хочу, чтобы старое сообщение было отброшено, и поэтому я хочу, чтобы оно рассматривало время обработки как семантическое время.

каково поведение по умолчанию для акробатического окна для семантики времени, как мне указать в акробатических окнах, какое время выбрать для семантики? Время события / время обработки / время приема.

1 Ответ

2 голосов
/ 15 апреля 2019

Семантика времени не указывается в определении окна, но зависит от настроенного TimestampeExtractor. Если вы хотите переключиться на семантику времени обработки, вы можете установить default.timestamp.extractor на WallclockTimestampExtractor.class в конфигурации KafkaStreams.

Сравните

...