kafka mongodb 接收器连接器未启动

Question

我已经安装了 confluent_3.3.0 并启动了 zookeper、schema-registry 和 kafka broker。我还从 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

感谢阅读！

Answer 1

此连接器使用的是最新版本的旧版 kafka-clients API。具体来说，它依赖于 Apache Kafka 版本 >= 0.11.0.0

中不存在的 class org.apache.kafka.common.config.AbstractConfig 的构造函数

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

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

kafka mongodb 接收器连接器未启动

kafka mongodb sink connector not starting

mongodb

apache-kafka

apache-kafka-connect