Kafka合流JDBC连接器无效值答案

【问题标题】：Kafka confluent JDBC connector invalid valueKafka合流JDBC连接器无效值
【发布时间】：2017-10-26 10:15:07
【问题描述】：

我使用 kafka jdbc confluent connector 3.x 从 Oracle 获取数据并将其发布到 Kafka 服务器。

属性文件配置如下。

name=demo-jdbc-source
connector.class=io.confluent.connect.jdbc.JdbcSourceConnector
connection.url=jdbc://db_config  
table.whitelist=Table_test
tasks.max=1 
mode=incrementing 
incrementing.column.name=TEST_ID
topic.prefix=jdbc-source-

运行时出现如下错误：

> Invalid value io.confluent.connect.jdbc.JdbcSourceConnector for
> configuration connector.class: Class
> io.confluent.connect.jdbc.JdbcSourceConnector could not be found.

【问题讨论】：

标签： jdbc apache-kafka apache-kafka-connect

【解决方案1】：

Kafka Connect 似乎找不到 JDBC 连接器 JAR。

您是在使用 Confluent Platform 本身，还是在现有的 Kafka 部署中使用 JDBC Connector？在前者中，路径将自动设置。如果是后者，您需要确保 kafka-connect-jdbc-3.3.0.jar 在您的 CLASSPATH 中（或在您的 Connect 工作人员配置中使用 plugin.path configuration option）

【讨论】：

我正在使用 JDBC 连接器，哪一个是最好的方法？使用融合平台或 jdbc 连接器！
Confluent 平台包括 JDBC 连接器。因此，您可以只使用 Confluent Platform，也可以使用其他地方的 Kafka 并单独下载 JDBC 连接器。