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 上安装连接器
Locate and download the uber JAR to get all the dependencies required for the connector. Check the reference table to find the 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-2.0.5-all.jar是版本2.0.5的 uber JAR connector 。