java - 如何将 mssql jdbc 驱动程序安装到 confluence/kafka

Question

我试图通过其余部分创建一个连接器，但它不起作用，并指出“无法找到任何实现连接器且名称与 com.microsoft.sqlserver.jdbc.SQLServerDriver 匹配的类

我在 ubuntu 16.04 上，我尝试了以下操作，每次尝试新的东西时，我都会停止，然后使用 confluence stop confluenct start

下载mssql-jdbc-6.2.2.jre8.jar

导出 CLASSPATH=/path/to/dir/* cp 路径/to/mssql-jdbc-6.2.2.jre8.jar/usr/share/rest-utils cp路径/to/mssql-jdbc-6.2.2.jre8.jar/usr/share/java/kafka cp路径/to/mssql-jdbc-6.2.2.jre8.jar/usr/share/java/kafka-connect-jdbc cp 路径/to/mssql-jdbc-6.2.2.jre8.jar/usr/share/java/res-utils cp路径/to/mssql-jdbc-6.2.2.jre8.jar/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/ext

文档让我看起来好像我所做的就是将/path/to/jar 添加到类路径并启动 confluence。我缺少什么。

此外，这是我用于创建连接器的 json。

{
  "name": "jdbc-source",
  "config": {
    "connector.class": "com.microsoft.sqlserver.jdbc.SQLServerDriver",
    "tasks.max": "1",
    "connection.url": "jdbc:sqlserver://sql:1443;User=someone;Password=password;Database=some-deb",
    "mode": "incrementing",
    "incrementing.column.name": "id",
    "topic.prefix": "email",
    "topic.whitelist": "EventLog",
    "name": "jdbc-source"
  }
}

Answer 1

事实证明，connector.class 应该保留 io.confluent.connect.jdbc.JdbcSourceConnector所以我认为这些步骤就足够了。

1. 添加您的mssql-jdbc-6.2.2.jre8.jar到类路径
2. confluent start
3. 发布问题中的配置并将connector.class替换为io.confluent.connect.jdbc.JdbcSourceConnector :我还必须删除端口