Создание коннектора раковины kafka для таблицы с первичным ключом в виде трех столбцов - PullRequest
0 голосов
/ 22 апреля 2020

Я создал исходный соединитель jdb c для таблицы, у которой нет первичного ключа (таблица имеет столбец a, b, c, d, e), и она является частью внешней базы данных. У меня есть таблица реплик в моей базе данных, и я создал первичный ключ, используя столбцы a, b и c, поскольку эти три, объединенные вместе, образуют уникальные данные и могут использоваться для формирования первичного ключа. Я пытаюсь создать соединитель приемника upsert и передал pk.fields как a, b, c, но когда я запускаю соединитель приемника, он переходит в ухудшенное состояние, и я не вижу никакой ошибки в connect.log также. Я дал pk.mode как record_value и в pk.fields я дал его как a, b, c. Может кто-нибудь, пожалуйста, дайте мне знать, если что-то не хватает в настройке?

Примечание: это работает, если я изменю режим для вставки и удаления pk.fields. pk.mode is record_value.

Обновление:

Привет, Робин. В исходной таблице с именем AccountDetails есть столбцы accNumber, bankABA, bankOrigAccNumber, SpendingLimit и ExpirationDate, и первичного ключа для этой таблицы нет. Целевой таблицей является AccountInformation, и она имеет те же столбцы, но имеет первичный ключ, как (accNumber, bankABA и bankOrigAccNumber), поскольку нам необходимо иметь первичный ключ в качестве целевого для использования в другом приложении. Я создал соединитель источника, который работает нормально, чтобы получить данные один раз в 24 часа. Я пытаюсь создать соединитель приемника с режимом upsert для передачи данных из topi c в таблицу и режим первичного ключа в виде record_value, а поля первичного ключа в виде "accNumber, bankABA, bankOrigAccNumber". Когда я запускаю раковину, она переходит в ухудшенное состояние.

...