Apache Kafka Connect Маршрутизация сообщения на основе значения записи - PullRequest
0 голосов
/ 26 июня 2018

Я бы хотел направить сообщение на основе значения поля.

Я использую соединитель JDBC для извлечения данных из таблицы, подобной этой:

id      table       change                  
-------------------------------------------------------------------------------------------------
3       dbo.Pets    {"OP":"UPDATE", "Id":"3", "Name":"Rufus","Type":"Cat","Number":"10482638"}
4       dbo.Pets    {"OP":"INSERT", "Id":"", "Name":"Misifu","Type":"Reddy","Number":"85745874"}

И я хотел бы направить каждую запись, используя поле Имя json, содержащееся в значении столбца изменения. Затем я должен извлечь значение столбца изменения, а затем извлечь значение имени.

В этом примере я хотел бы:

  • Направьте первую запись в тему Pets_Name_Rufus.
  • Направьте вторую запись в тему Pets_Name_Misifu.

Но я не знаю, можно ли это сделать с помощью преобразований.

Большое спасибо:)

...