Может ли кафка фиксировать изменения в представлениях базы данных - PullRequest
0 голосов
/ 30 ноября 2018

Возможно ли для потоковой передачи kafka зафиксировать изменения в представлении базы данных?У меня есть представление в базе данных с столбцами из нескольких таблиц.Так будет кафка обнаруживать изменение данных в представлении

1 Ответ

0 голосов
/ 30 ноября 2018

Нет, Kafka не взаимодействует ни с одной базой данных.

Если вы можете периодически запрашивать представление с использованием JDBC, тогда вы можете использовать JDBC Source Connector для получения тех же строк данных, что и записи Kafka.

Или вы можете использовать продукт CDC, такой как , чтобы вывести все отдельные релевантные таблицы, которые использует представление, и объединить их в KStreams / KSQL для воссоздания всей материализованной таблицы представления, но при поддержкепоток

...