по on_update как аргумент функции приходит автоматом - куда там конвертацию приложить?
сделал table такого типа {op=op, s=s и т.д.} главное чтобы old был последним. это конвертнул через тарантуловский модуль json и отправил в кафку. все получилось.
Обсуждают сегодня