Kafka confluent JDBC connector invalid value

0
votes

I used kafka jdbc confluent connector 3.x to get data from Oracle and publish it to Kafka server.

The property file configuration is here below.

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-

While running it getting an error like: 

> Invalid value io.confluent.connect.jdbc.JdbcSourceConnector for
> configuration connector.class: Class
> io.confluent.connect.jdbc.JdbcSourceConnector could not be found.
1
jdbcapache-kafkaapache-kafka-connect

1 Answers

1
votes

It looks like the JDBC connector JAR can't be found by Kafka Connect.

Are you using 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 on your Connect worker config)