коннекторов) отличается на 1 или на 3 (в другом топике)
как подойти к поиску, какое сообщение не дошло до БД?
может кто сталкивался
Если используешь кафка коннект и есть ключи уникальности на таблице, то самое простое отмотать оффсет назад и дать коннекту ещё раз все перевычитать. У коннектора должен быть включен мод upsert
Сейчас включён upsert, а в чем принципиальная разница между insert и upsert? Пока не могу понять. В доке к коннектору всё так сухо.
https://docs.confluent.io/cloud/current/connectors/cc-postgresql-sink.html#features в доке же первым пунктом написано
А почему различается при включенном upsert - ну, наверное у вас в топике на один ключ уникальности - несколько записей. В постгресе соответственно будет только одна запись.
спасибо. чуть позже сброшу офсет, попробую ещё раз прогнать. проверю.
Обсуждают сегодня