首页 > 解决方案 > Kafka 源 - 接收器连接器 - 具有单个主题的多个表

问题描述

将来自不同表的消息填充到单个主题。但是需要分离出消息并接收到具有相同名称的目标表集。

使用 debezium/connect,我使用 jdbc 源连接器从源表中填充主题。使用 jdbc sink 连接器,我填充目标表。(从主题到目标表)在这种情况下,我需要 1 个主题用于 1 个表。由于有 100 个表,我需要一个主题来同步许多表

知道如何实现这一目标吗?

标签: jdbcapache-kafkaapache-kafka-connect

解决方案


您可以使用 Kafka Connect 转换在运行中修改主题/表名称。

看来您可能想使用 aRegexRouter来收集多个主题。

https://docs.confluent.io/current/connect/transforms/regexrouter.html


推荐阅读