Мы используем Kafka Streaming для нашей долгосрочной задачи потоковой передачи. Заданная нами активность - 10 минут. Перед тем, как перевести наше приложение в производство, мы беспокоимся о неактивности сеанса ... Может случиться, что окно всегда получает данные, а продолжительность бездействия никогда не достигает. Как мы истекаем окно сеанса? Мы не хотим, чтобы окно сеанса полагалось только на активность. Как мы должны истечь окно сеанса, если сеанс становится слишком длинным и в активности не достиг.
Это может произойти, если опоздавшие данные продолжают объединять существующие сеансы? Как мы должны обращаться с этим вариантом использования?