пунктуатор не будет вызван.
По условию задачи, время таймаута ивента индивидуально для каждого ивента. Таким образом, если оно варьируется, скажем, в интерваале 1..10 минут, то для стрима нужно будет постаавить пунктуацию как минимум раз в минуту.
Однако, в таком случае получится ситуация:
1) В топик попала пачка ивентов с expiration time +1min, +3min и +10min
2) После этого в топик, допустим еще минуту-две шли ивенты
3) Пунктуация случится для +1 и +3 минуты, однако некому будет закрыть то, что должно закрыться на +10 минут
верно?
если мне память не изменяет там можно указать какое время использовать, системное или из евентов
Обсуждают сегодня