Kafka 融合 JDBC 连接器值无效

Question

我使用 kafka jdbc 融合连接器 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.

Answer 1

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

您是否在 Connect worker 配置中使用 Confluent Platform itself, or the JDBC Connector alongside your existing Kafka deployment? In the former the paths will be set up automagically. If the latter you'll need to make sure that kafka-connect-jdbc-3.3.0.jar is on your CLASSPATH (or use the plugin.path configuration option

Kafka 融合 JDBC 连接器值无效

Kafka confluent JDBC connector invalid value

jdbc

apache-kafka

apache-kafka-connect