安装 MongoDB Kafka Connector
Overview
了解如何安装 MongoDB Kafka Connector。该连接器适用于 Confluent Platform 和 Apache Kafka 部署。如需查看适合您部署类型的安装说明,请导航至以下部分之一:
在 Confluent 平台上安装连接器
单击以下选项卡可查看有关如何在 Confluence 平台上安装连接器的说明:
使用 Confluent Hub Client 按照适用于 MongoDB Connector for Apache Kafka 的安装说明进行操作。
按照 Confluent 页面上的说明 手动安装社区连接器。
在适当的时候,使用 Confluence connectorGithubURL手动安装说明中 参考表 中的 和 uber JAR 位置。
在 Apache Kafka 上安装连接器
找到并下载 uber JAR 以获取连接器所需的所有依赖项。检查参考表以查找 uber JAR。
注意
如果您无法使用 uber JAR 或更愿意管理自己的依赖项,请下载包含所需最少依赖项的 JAR 并解析所有运行时依赖项。 您可以使用插件,例如 Maven dependency:tree 生成依赖树。
将 JAR 和所有依赖项复制到 Kafka 插件目录中,您可以在 plugin.path 中指定该目录 配置设置(例如
plugin.path=/usr/local/share/kafka/plugins
)。
注意
如果您打算将连接器作为分布式工作进程来运行,则必须为每台服务器或虚拟机重复执行此流程。
下载连接器 JAR 文件
您可以从以下位置中下载 Connector 源文件和 JAR 文件:
Kafka Connector GitHub 存储库(源代码) | |
Maven 中央存储库(JAR 文件) |
您可以通过文件名中的后缀来识别 JAR 文件的内容。有关各后缀的说明,请参见下表:
后缀 | 说明 |
所有 | 包含连接器、MongoDB 依赖项和 Apache Avro 的 uber JAR |
confluent | 包含连接器和 Confluence 平台的最低要求 |
javadoc | 包含连接器类 Javadoc 文档 |
来源 | 包含与已编译连接器类相对应的源代码 |
例如, mongo-kafka-connect-1.13.1-all.jar
是版本1.13.1的 uber JAR connector 。