Кажется, что kafka и ksql могли бы справиться с этим элегантно, но мне трудно найти его: может ли тема состоять только из набора изменений из потока?В качестве надуманного примера, скажем, тема users содержит метаданные пользователя, включая user_id, title, nickname и так далее.Есть ли способ
create table title_change as
select user_id, title from users ...
и получить тему user_id, title, которая заполняется только при смене названия?Желаемый эффект заключается в том, что если новое сообщение поступит в users с тем же заголовком, новое сообщение не будет отправлено на title_change.Использование group by user_id, title является почти идеей, но все равно отправляет сообщение о любом входе на users