#mysql #apache-kafka #apache-kafka-connect
Вопрос:
У меня есть мультитенантное приложение Kafka Streams, которое транслирует вставки таблиц MySQL (с использованием Debezium) из таблицы «исходные события» из нескольких схем («организация1″,»организация2», ….) в одну тему «исходные события».
Например: событие 1 = {«ключ1″:»значение1″,»организация»:»ограничение1″}. событие 2 = {«ключ2″:»значение2″,»организация»:»ограничение2″}.
Я использую JdbcSinkConnector для хранения событий в таблице базы данных MySQL «enriched_events».
Можно ли настроить приемник подключения JDBC для мультиплексирования/маршрутизации событий в разные базы данных в одну и ту же таблицу на основе поля события «org»?
т. е. событие 1 будет вставлено как строка в схему «ogranization1», таблица «enriched_events» и событие 2 будут вставлены как строка в схему «ogranization2», таблица «enriched_events» соответственно?
Очевидным решением является создание темы приемника для каждого арендатора/организации, но для этого требуется указать как количество соединителей приемника, так и количество арендаторов/организаций.
Например, в соединителе источника Debezium я могу использовать «преобразования.Перенаправить» и предоставить регулярное выражение для таблицы с несколькими схемами, которые будут перенаправлены в одну тему. Но можно ли выполнить обратную операцию?