apache-kafka-connect - 带有 JDBC for Sybase 的 Kafka 连接器 - SQLException:”\”\” 不是有效的类型名称
问题描述
我正在使用 Kafka JDBC 连接器捕获 Sybase 上的更改数据进行 POC。但是在为 Sybase 创建源连接器时,我收到以下错误消息。
“连接器配置无效并包含以下 2 个错误:无效值 java.sql.SQLException:”"" 不是有效的类型名称。用于配置无法打开与 jdbc:sybase:Tds:hostname:port/dbname 的连接\n无效值 java.sql.SQLException:"" 不是有效的类型名称。用于配置无法打开与 jdbc:sybase:Tds:hostname:port/dbname 的连接。
Confluent 版本:5.3.1 Kafka 连接 jdbc:5.3.1 与 Sysbase 连接:jconn4.jar
连接细节:
{
“名称”:“sybase_source_conn”,
“配置”:{
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"connection.url": "jdbc:sybase:Tds:XXX.XXX.XXX.:XXXX/DB",
"connection.user": "XXXXX",
"connection.password": "XXXXXXX",
"topic.prefix": "test_sybase",
“模式”:“时间戳”,
“timestamp.column.name”:“last_updt”,
“查询”:“从表名中选择 *”
}
}
请指导我解决这个问题。
谢谢, Senthil Kumar A
解决方案
推荐阅读
- php - 如何从数组中检索元素 - PHP
- .net - 我可以将流读入包含 Unicode BOM 的字符串吗?
- php - 如何从我的数据库中获取一个值并在输入字段中使用和显示它?
- android - 如何从事件处理程序中获取调用者作为 Kotlin 中的对象
- wpf - 为什么 VS2017 WPF 应用程序属性给我错误?
- mysql - Mysql 5.7 在 GENERATED 列中使用 IF THEN 或 CASE WHEN
- google-play - 如何正确更新 Ionic 4 应用程序以将其上传到 Google Play 商店?
- javascript - 在多个条件下过滤对象数组
- c# - 如何在边框之后绑定我的文本?
- angular - Angular 服务不是那么单一