выглядит не очень оптимально. может кто-то с большим опытом прокомментирует.
а вот по поводу Stream'а у меня вопрос: я же правильно понимаю, что этот стрим кладет что-то в KTable по ключу correlationId?
Кафка топик изначально представляется в виде KStream ,если применить метод filter то получим KStream - это по прежнему ближе к топику, а KTable это для хранения состояния , данные с одним ключём перезаписывается. Но в нашем случае по моему достаточно KStream.
тогда как этот фильтр сработает? на каждый correlationId будет создаваться свой KStream?
Обсуждают сегодня