Я импортирую данные из таблицы MS SQL Server в тему Apache Kafka с помощью Kafka Connect.
Столбец изменений представляет собой массив json, который я хотел бы сгладить и отправить в несколько событий.
Записи таблицы выглядят так:
id table change
-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
3 dbo.Pets {"change":[{"OP":"UPDATE", "Id":"3", "Name":"Rufus","Type":"Cat","Number":"10482638"}, {"OP":"INSERT", "Id":"", "Name":"Misifu","Type":"Reddy","Number":"85745874"}]}
И что мне нравится вставлять в тему:
id table change
-------------------------------------------------------------------------------------------------
3 dbo.Pets {"OP":"UPDATE", "Id":"3", "Name":"Rufus","Type":"Cat","Number":"10482638"}
3 dbo.Pets {"OP":"INSERT", "Id":"", "Name":"Misifu","Type":"Reddy","Number":"85745874"}
Кто-нибудь может мне помочь? Большое спасибо :)
