kafka mongodb sink 连接器未启动答案

【问题标题】：kafka mongodb sink connector not startingkafka mongodb sink 连接器未启动
【发布时间】：2018-04-20 21:20:28
【问题描述】：

我已经安装了 confluent_3.3.0 并启动了 zookeper、schema-registry 和 kafka 代理。我还从this link下载了mongodb连接器。

说明：我正在使用以下命令运行接收器连接器：

./bin/connect-standalone etc/kafka/connect-standalone.properties /home/username/mongo-connect-test/kafka-connect-mongodb/quickstart-couchbase-sink.properties

问题：我收到以下错误：

ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:91)
java.lang.IllegalAccessError: tried to access field org.apache.kafka.common.config.ConfigDef.NO_DEFAULT_VALUE from class org.radarcns.mongodb.MongoDbSinkConnector

感谢阅读！

【问题讨论】：

标签： mongodb apache-kafka apache-kafka-connect

【解决方案1】：

此连接器在其最新版本中使用的是旧版本的 kafka-clients API。具体来说，它依赖于 Apache Kafka 版本 >= 0.11.0.0 中不存在的类 org.apache.kafka.common.config.AbstractConfig 的构造函数

Confluent Platform 版本 3.3.0 正在使用 Apache Kafka 0.11.0.0

要解决此问题，推荐的方法是更新连接器代码以使用最新版本的 Apache Kafka API。

【讨论】：