2017-11-08 4 views
0

私はconfluent_3.3.0をインストールし、zookeper、schema-registry、kafka brokerを起動しました。そして、私はエラー ERRORは、コネクタのエラーが発生した後の停止(org.apache.kafka.connect.cliの下に取得しています./bin/connect-standalone etc/kafka/connect-standalone.properties /home/username/mongo-connect-test/kafka-connect-mongodb/quickstart-couchbase-sink.propertieskafka mongodbシンクコネクタが起動していません

コマンド以下

を使用して、シンクコネクタを実行

https://github.com/RADAR-CNS/MongoDb-Sink-Connectorリンクの下からMongoDBのコネクタをダウンロード.ConnectStandalone:91) java.lang.IllegalAccessError:クラスからフィールドorg.apache.kafka.common.config.ConfigDef.NO_DEFAULT_VALUEにアクセスしようorg.radarcns.mongodb.MongoDbSinkConnector

読んでいただきありがとうございます!

答えて

0

このコネクタでは、最新バージョンでkafka-clients APIの古いバージョンを使用しています。具体的には、

>= 0.11.0.0のApacheカフカのバージョンに存在しないクラス org.apache.kafka.common.config.AbstractConfigのコンストラクタに依存しているコンフルエントプラットフォームのバージョン 3.3.0この問題を解決するにはApacheのカフカ 0.11.0.0

を使用している、お勧めのアプローチは、更新することになります最新のバージョンのApache Kafka APIを使用するコネクタコード。

関連する問題