我使用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.
1条答案
按热度按时间slhcrj9b1#
看来kafka connect找不到jdbc连接器jar。
您是在使用confluent平台本身，还是在使用现有kafka部署的同时使用jdbc连接器？在前者中，路径将自动设置。如果是后者，你需要确保
kafka-connect-jdbc-3.3.0.jar在类路径上（或使用plugin.path连接工作者配置上的配置选项）