时间戳

首页 > 解决方案 > 如何设置 mongo-kafka-connect？

apache-kafka - 如何设置 mongo-kafka-connect？

问题描述

我没有使用融合，我能够Kafka成功运行 Zookeeper。并按照步骤Mongo-kafka使用 jar 文件进行连接，但出现错误。从 maven tech下载mongo-kafka-connect-0.2-all.jar文件后，我需要注册吗？我已经正确更新了插件路径。有人能帮助我吗？ 

com.mongodb.kafka.connect.MongoSinkConnectorINFO Kafka Connect started (org.apache.kafka.connect.runtime.Connect:56)
[2019-10-22 03:16:02,713] ERROR Failed to create job for config/MongoSinkConnector.properties (org.apache.kafka.connect.cli.ConnectStandalone:110)
[2019-10-22 03:16:02,714] ERROR Stopping after connector error (org.apache.kafka.connect.cli.ConnectStandalone:121)
java.util.concurrent.ExecutionException: org.apache.kafka.connect.errors.ConnectException: Failed to find any class that implements Connector and which name matches com.mongodb.kafka.connect.MongoSinkConnector, available connectors are: PluginDesc{klass=class org.apache.kafka.connect.file.FileStreamSinkConnector,

标签： apache-kafkaapache-kafka-connect

解决方案

您有一个错误，因为 Kafka Connect 没有加载您尝试使用的连接器 JAR：

Failed to find any class that implements Connector and which name matches com.mongodb.kafka.connect.MongoSinkConnector

您可以选择使用Confluent Hub 工具安装连接器 - 您可以在不运行 Confluent Platform IIRC 的情况下使用它：

confluent-hub install mongodb/kafka-connect-mongodb:0.2

Confluent Hub 工具可以plugin.path自动处理诸如此类的事情，因此您不必这样做。

或者，您可以自己配置它。确保plugin.path您的 Kafka Connect 工作人员设置为包含您拥有 MongoDB 接收器连接器 JAR 的文件夹。

推荐阅读