Nikolay
Подскажите про каппа архитектуру. Так я понял , что мы убираем батчин лэйр и оставляем только стриминг лэйр. И в случае необходимости запускаем репроцессинг лога. Но ведь лог будет огромен. Вот про размер этого лога и вопрос. Может подразумевается, что мы считаем агрегаты и как бы делаем репроцессинг не всего лога ?
Каппа архитектура (как и лямбда до нее), по моему мнению 🙂 это не архитектура в том смысле что описывает компоненты и их взаимодействие, а архитектурная концепция вокруг определенного датафлоу, в этом смысле то как вы оптимизируете рекавери, расчеты неаддитивных агрегатов - это детали реализации