如何安装 mssql jdbc 驱动程序以融合 / kafka

Question

我正在尝试通过其余部分创建一个连接器，

但说明该连接器"Failed to find any class that implements Connector and which name matches com.microsoft.sqlserver.jdbc.SQLServerDriver不起作用

我在 ubuntu 16.04 上，我已经尝试了以下内容，每次我尝试新的东西时，我都会停下来，然后开始与confluent stop confluenct start融合

下载 mssql-jdbc-6.2.2.jre8.jar

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

文档使我所做的一切看起来就是将/path/to/jar 添加到类路径并开始融合。我错过了什么。

此外，这是我创建连接器的 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

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

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