首页 文章

kafka mongodb水槽连接器无法启动

提问于
浏览 次
1

我已经安装了confluent_3.3.0并启动了zookeper，schema-registry和kafka broker . 并从下面链接下载mongodb连接器https://github.com/RADAR-CNS/MongoDb-Sink-Connector

使用以下命令运行接收器连接器

./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 回答

  • 0

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

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

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

    回复于

相关问题