我试图建立一个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"
}
}
有人知道如何在配置文件中正确解析它吗?
谢谢!
暂无答案!
目前还没有任何答案,快来回答吧!