Kafka Connect Transforms (SMT) - Помогите решить вариант использования - PullRequest
Новая
       13

Kafka Connect Transforms (SMT) - Помогите решить вариант использования

0 голосов
/ 11 марта 2019

У меня есть сценарий использования, в котором я хотел бы сопоставить поле ключа исходной таблицы с целевым ссылочным полем таблицы, используя соединитель источника или приемника kafka.

Я новичок в этом форуме, пожалуйста, дайте мне знать, если мне не хватает, чтобы добавить какую-либо информацию.Заранее спасибо!

1 Ответ

0 голосов
/ 12 марта 2019

Вы должны использовать: org.apache.kafka.connect.transforms.ReplaceField$Value Преобразование

Раздел конфигурации с преобразованием должен выглядеть следующим образом: 

{
    ...
    "transforms": "RenameField",
    "transforms.RenameField.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
    "transforms.RenameField.renames": "SRC_ID:SRC_REF_ID"
    ...
}

Если ваш столбец SRC_ID имеет тип Int, вам также может потребоваться приведение к String. Для этого вы можете использовать: org.apache.kafka.connect.transforms.Cast

Более подробно о трансформации по умолчанию можно найти: https://kafka.apache.org/documentation/#connect_transforms

...