将不同表中的消息填充到单个主题中。但需要将消息分离出来,并汇到具有相同名称的目标表集。
使用debezium/connect,我使用jdbc源连接器从源表填充主题。使用jdbc接收器连接器,我填充目标表。(从主题到目标表(在这个场景中,我需要1个主题对应1个表。由于有100个表,我需要有一个单独的主题来同步许多表
知道如何做到这一点吗?
您可以使用Kafka Connect转换来修改飞行中的主题/表名称。
看来您可能想要使用RegexRouter
来收集多个主题。
https://docs.confluent.io/current/connect/transforms/regexrouter.html