Доступно ли это, если Kafka Sink использует несколько приемников в несколько таблиц с автономной конфигурацией? - PullRequest
0 голосов
/ 14 марта 2020

Я прочитал, что источник подключения Kafka может получать несколько тем из базы данных (топи c представляют одну таблицу). У меня есть PostgreSQL база данных со многими таблицами, и один источник Kafka достаточно удовлетворен для этого времени. Но доступно ли это, если я объявлю только один приемник JDB C Kafka для использования всех тем в таблице назначения на основе topi c, например, всех таблиц из PostgreSQL в одну базу данных сервера MS SQL? Это временные затраты, например, если у меня есть 200 таблиц из одной базы данных и мне нужно установить 200 приемников для каждой таблицы, хотя мне нужно только один раз объявить источник.

1 Ответ

1 голос
/ 14 марта 2020

Вы можете использовать Debezium для моментального снимка одной базы данных и всех таблиц для отправки их через Kafka и дампа на любой другой соединитель приемника (включая MS SQL), да

Сколько соединителей вам нужно запустить или как многие таблицы в месте назначения, которое вы создадите, в конечном итоге соответствуют вашим собственным конфигурациям

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

...