KSQL таблица получает старое и новое значение

Question

Возможно ли в KSQL вывести старые и новые значения из таблицы?Мы хотели бы использовать таблицу в качестве хранилища значений, и когда кто-то меняет поток, выводят «обратное» значение, которое является предыдущим, помеченным каким-либо образом, и новое значение, чтобы мы могли просто обрабатывать дельту в последующих системах

Answer 1

Таблицы Кафки обычно используются для хранения последних значений.Так, например, скажем, что поток с ключом «123» существует в таблице, а новый поток с тем же ключом «123», но в столбце появляется другое значение столбца, это переопределит (упростит) существующее значение в таблице.

ИтакВероятно, это не очень хорошая идея сделать это в таблице.

Ваш вариант использования мне не ясен, но я предлагаю вам иметь какой-то механизм либо в источнике потока, либо с использованием метки времени для работы с дельтойкормить.