如何将 mssql jdbc 驱动程序安装到 confluent / kafka答案

【问题标题】：How do I install mssql jdbc driver to confluent / kafka如何将 mssql jdbc 驱动程序安装到 confluent / kafka
【发布时间】：2018-01-18 04:48:15
【问题描述】：

我正在尝试通过其余部分创建一个连接器，但它无法说明"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"
  }
}

【问题讨论】：

标签： java jdbc apache-kafka confluent-platform

【解决方案1】：

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

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

【讨论】：