мгновенных событий, а, например, для расчёта продолжительности событий, сгруппированных по некоторым полям и временному окну. Хотя и для других платформ, типа флинка и спарка, подобного не находил. Но вопрос про кафку. Можно, конечно, всё сделать в кастомном процессоре, но может быть есть вариант проще? Подходят ли вообще стримы для таких задач или их используют для мгновенных событий, типа кликов и показов?
А для чего? Если для хранения агрегатов в базу или для оргагизации еще одного стрима событий?
Обсуждают сегодня