WindStill opened a new issue, #44: URL: https://github.com/apache/doris-kafka-connector/issues/44
请问能不能支持 `org.apache.kafka.connect.transforms.RegexRouter` 啊？ 我这边10来个MySQL库的几十张表需要同步到doris，如果用 `doris.topic2table.map` 属性的话，得手动写几十个topic与table的对应关系。 但是如果用之前同步到CrateDB的JDBC方式，只要加个 RegexRouter 的transform就可以映射topic与目标table了，如下： ``` "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter", "transforms.route.regex": "([^.]+)\\.([^.]+)\\.([^.]+)", "transforms.route.replacement": "kafka_test.$3" ``` > debezuim 同步MySQL到kakfa的topic默认名称为 `dbserver.dbname.tablename`。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
