У меня две проблемы.
1) Я включил delete.enabled как true. Но поскольку для него необходимо установить pk.mode как record_key, я не могу использовать составной ключ моей таблицы MySQL, как я мог бы использовать, когда я установил pk.mode как record_value. Я попытался добавить составной ключ в поток при преобразовании записей в формат AVRO, используя параметр partition by. Но в таблицу MySQL добавлен новый столбец. Строка не устанавливается, если я использую один первичный ключ вместо составного ключа.
2) Режим удаления не работает в моем соединителе приемника. Я использовал insert.mode как upsert. Моя таблица MySQL содержит поля с атрибутом not null. Выдается ошибка: Col has a not-null attribute. It cannot be null. Для удаления я удаляю все значения в записи, кроме значения первичного ключа. Пример надгробной записи для операции удаления - ,,,,,,,,<primary key value>,,,,,,,,,. Если я добавляю значения для всех тех столбцов, которые имеют атрибут not-null, выполняется операция обновления. Кроме того, я хочу знать, делаю ли я какую-либо ошибку при создании надгробной записи.