Kafka подключаем исходный разъем с помощью JDB C и отдыхаем - PullRequest
0 голосов
/ 05 мая 2020

Проблема: мне нужно поместить коннектор в таблицу базы данных и получить записи и sh публикации на основе последнего изменения ts. Проблема в том, что строки таблицы жестко удалены в некоторых случаях, для которых я не могу сгенерировать события. Например: есть 2 таблицы - адрес и лицо. Предположим, у меня есть таблица адресов, связанная с таблицей людей. У одного человека может быть несколько адресов. И я должен генерировать события для этой адресной таблицы. В случае, если адрес человека удален, таблица лиц last_change ts обновляется, а строка удаляется из адреса.

Подход, о котором я думал, таков: используйте объединение таблицы людей и адресов и публикации sh событие, основанное на последнем изменении таблицы людей. Но проблема в том, что событие удаления не будет правильным, так как оно не скажет, какой адрес удален.

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

Есть ли способ сделать это?

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

Я могу справиться с этим другим способом?

Я не могу вносить изменения в слушателя этих событий, поскольку слушатель не может выполнять вызовы БД.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...