kafka connect jdbc sink isse,表名包含“.”

hgncfbus  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(226)

我试图建立一个Kafka连接jdbc接收器连接器。问题是,数据库表名包含一个点,创建连接器时,进程将表名一分为二,导致数据库表未找到。我尝试了多种方法来转义点,以便它可以作为表名中的字符串来读取,但没有任何效果。。
以下是实际名称:
“table.name.format”:“bte3\u myname.centrallogging”,
错误如下:
原因:org.apache.kafka.connect.errors.connectexception:缺少表\“bte3\u myname\”、\“centrallogrecord\”。
这是我的配置文件:

{
    "name": "jdbc-connect-central-logging-sink",
    "config": 
    {
        "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
        "tasks.max": "3",
        "topics": "central_logging",

        "connection.url": "...",         
        "connection.user": "...",
        "connection.password": "...",
        "table.name.format":"Bte3_myname.centrallogging",
        "pk.mode": "kafka",

        "auto.create": "false",
        "auto.evolve": "false"
    }
}

有人知道如何在配置文件中正确解析它吗?
谢谢!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题