Kafka Sink 如何将字段映射到具有不同主题和表模式名称的数据库

Question

我目前正在使用主题名称 waiting-room 设置 Kafka Sink 连接器，而我的数据库架构称为 waiting_room。所以我试图将主题消息映射到数据库模式，但我没有看到任何数据进入数据库。 所以我尝试了以下场景：

1. 因此，由于表架构是 waiting_room，我尝试添加 quote.sql.identifier=ALWAYS，因为它引用表名并允许 Kafka 接收器引用它，以便它可以映射到表，但我在 Kafka 中没有看到 quote.sql.identifier=ALWAYS下沉。 table.schema 和 Kafka 接收器是否都需要引用才能映射它，或者我如何将表模式映射为下划线并让 kafka 映射它
2. 然后，如果我更改了 table.name.format=waiting-room 并让 db schema = gt.namespace."waiting-room" 我看不到我的 kafka 接收器得到更新，但我的 table.name.format 将 = waiting_room 并具有状态连接器的 404 未找到。

当主题和数据库名称不同时，有没有办法映射并将数据输入数据库

Answer 1

尝试使用Kafka Connect SMTRegexRouter：

{
    "task.max": "1",
    "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
    "connection.url": "'"$URL"'",
    "topics": "waiting-room",

    "transforms": "route",
    "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter",
    "transforms.route.regex": "waiting-room",
    "transforms.route.replacement": "gt.namespace.waiting_room",

    "errors.tolerance": "all",
    "errors.log.enable": "true",
    "errors.log.include.messages": true
}