Заодно и для авторизации написал

Специалисты по Kafka Stream, такой вопрос.
Я делаю tumbling window, предположим в час. Все что я делаю в окне - это считаю ивенты. По итогу окна я делаю suppress и вывожу сумму за час.

1. Что случиться если после 30 минут от начала окна приложение упадет и поднимется снова с голой памятью? Потеряю ли я счет первого получаса?

2. Хранит ли Kafka Streams все сообщения от текущего часа в памяти или только одну цифру аггрегат - каунт событий?

500 строк максимум там

Понятно, то есть либо ентерпрайз решение от конфлюент,  либо писать самим))
На чем писал, если не секрет?

На Java

Есть репа в которой пример положил, но там реализация с  аутентификацией на стороннем сервере (сервер в комплекте для теста) . По сути заменить коннект к серверу на bind LDAP сервера. LDAP даже проще.
Выложить код с LDAP не могу, поскольку все же это на работе писал. Но могу рассказать что на что заменить.

В чем может быть проблема, что Kafka Stream не читает топик? Запускаю стандартный пример, ноль реакции. Кафка крутится в докере. Могу записать и прочитать в топик обычным способом (Producer/Consumer)

А точно что она не читает а не не пишет?

Потому что по умолчанию стоит таймаут на запись

Я добавил .foreach с логом в консоль и ничего не вижу. После запуска .start тишина

Ну ресетни офсет

И посмотреть если получится перепрочитать

Да я новый создал, накидал в него сообщенек (и до, и после запуска стрима), то же самое.

Я правильно понимаю, что .foreach будет просто читать сообщеньки и выпополнять для каждой код в фоне?

Кож можно глянуть?

Да, примерно так: https://gist.github.com/54e4ac4eb77bff677887484a88de37b1

бля

Ты издеваешься?

Вот это поворот

Ну а что