我已经安装了Confluent3.3.0并启动了zookeper、SchemaRegistry和kafka代理。我也从这个链接下载了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感谢阅读！
1条答案
按热度按时间rjjhvcjd1#
此连接器正在使用最新版本的kafka客户端api的旧版本。具体来说，它取决于类的构造函数
org.apache.kafka.common.config.AbstractConfig这在apachekafka版本中并不存在>= 0.11.0.0合流平台版本3.3.0正在使用ApacheKafka0.11.0.0要解决此问题，建议的方法是更新连接器代码以使用最新版本的apachekafkaapi。