2017-10-26 8 views
0

私はkafka jdbcコンフルエントコネクタ3.xを使用してOracleからデータを取得し、それをKafkaサーバーに公開しました。カフカ合流JDBCコネクタ無効な値

プロパティファイルの設定は以下のとおりです。

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- 

のようなエラーを取得し、それを実行している間:それは、JDBCコネクタJARのように見えます

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

答えて

1

はカフカConnectで見つけることができません。

Confluent Platform、またはJDBC Connectorを既存のカフカの配備と一緒に使用していますか?前者の場合、パスは自動的に設定されます。後者の場合は、kafka-connect-jdbc-3.3.0.jarがCLASSPATHにあることを確認する必要があります(または、Connectワーカーの設定でplugin.path configuration optionを使用してください)

+0

私はJDBCコネクタを使用しています。コンフルエントなプラットフォームまたはjdbcコネクタを使用してください! – Raju

+1

Confluent Platformには、JDBCコネクタが含まれています。そのため、Confluent Platformを使用することも、別の場所からKafkaを使用してJDBCコネクタを個別にダウンロードすることもできます。 –

関連する問題