Я использую debezium для сбора изменений из 4 таблиц из моей БД книжного магазина, модель данных - это структура EAV (сильно нормализована).
books:
атрибуты book:
book_value_int:
book_value_varchar ... аналогично book_value_int
Моя цель - создать выходную тему, которая при использовании в виде таблицы KTable будет эквивалентна следующей:
Я новичок в Stream Processing, я пытался с помощью KS DSL присоединиться к темам.Мои усилия до сих пор имели переменный успех.Этот тип операции лучше подходит для API процессора?