У меня есть тема Кафки. У меня есть поток с ключом, являющимся символом акции, и значением, являющимся pojo Привет / Низко. У меня также есть KTable, который фиксирует текущее состояние потока.
Я хочу обработать каждую запись в потоке одну за другой. Для каждой записи я хочу посмотреть текущее значение этого символа из таблицы KTable. Затем, в зависимости от того, изменяется ли Hi / Low, я хочу обновить таблицу KTable и затем записать сообщение в поток.