После этого урока от @ robin-moffatt. В основном я пытаюсь обогатить каждое событие изменения из debezium mon go topi c некоторыми свойствами, которые не изменяются в каждом событии. Например, свойство "language"
в учебнике предлагается
ksql> CREATE STREAM DEVICE (after VARCHAR) WITH (KAFKA_TOPIC='ubnt.ace.device-07',VALUE_FORMAT='JSON');
ksql> select EXTRACTJSONFIELD(after,'$.language')from device;
Но события mongodb debezium для обновлений находятся не в "after" json, а в "patch" json строка Мой вопрос - как я могу сохранить эту таблицу / поток обновленным с последним изменением "языка" - независимо от того, откуда оно появилось (после или после патча)
Спасибо