Можно ли в KSQL передавать старые и новые значения из таблицы? Мы хотели бы использовать таблицу в качестве хранилища значений, и при изменении потока выводится значение "разворота", которое является предыдущим, каким-то образом помечено тегами, и новое значение, чтобы мы могли просто обрабатывать дельту в последующих системах. ?
Таблица KSQL получает старое и новое значение
Ответы (1)
Таблицы Kafka обычно используются для хранения последних значений. Так, например, скажем, что поток с ключом «123» существует в таблице, и новый поток с тем же ключом «123», но в теме отображается другое значение столбца, это переопределит (обновит) существующее значение в таблице.
Так что, вероятно, делать это на Table - не лучшая идея.
Ваш вариант использования мне не ясен, но я предлагаю вам иметь какой-то механизм либо в источнике потока, либо с использованием метки времени для работы с дельта-фидом.
person
Mehul Gupta
schedule
02.10.2018
Для этого мы могли бы добавить специальный процессор в тему, я просто подумал, что это подойдет для KSQL.
- person Ben; 03.10.2018
Правильно, вы также можете попробовать настраиваемый коннектор Kafka для извлечения данных из различных источников или вы можете написать свой собственный коннектор для извлечения дельта-каналов.
- person Mehul Gupta; 03.10.2018
