安装 MongoDB Kafka 连接器
概述
了解如何安装 MongoDB Kafka 连接器。该连接器适用于 Confluent 平台和 Apache Kafka 部署。要查看您部署类型的安装说明,请导航到以下部分之一
在 Confluent 平台上安装连接器
点击以下选项卡,查看如何在 Confluent 平台上安装连接器的说明
按照以下说明使用 Confluent Hub 客户端安装 MongoDB Apache Kafka 连接器。
按照Confluent页面上的说明手动安装社区连接器。手动安装社区连接器。
在Confluent的手动安装说明中,适当使用连接器GitHub URL和uber JAR位置,参考参考表。
在Apache Kafka上安装连接器
找到并下载uber JAR以获取连接器所需的所有依赖项。检查参考表以找到uber JAR。
注意
如果您无法使用uber JAR或希望自行管理依赖项,请下载包含最小必需依赖项的JAR文件,并解决任何运行时依赖项。您可以使用Maven依赖项:tree插件来生成依赖项树。
将JAR文件和任何依赖项复制到Kafka插件目录中,您可以在您的plugin.path配置设置中指定(例如
plugin.path=/usr/local/share/kafka/plugins
).
注意
如果您打算以分布式工作进程运行连接器,则必须在每个服务器或虚拟机上重复此过程。
下载连接器JAR文件
您可以从以下位置下载连接器的源代码和JAR文件
Kafka连接器GitHub仓库(源代码) | |
Maven中央仓库(JAR文件) |
您可以通过文件名后缀来识别JAR文件的内容。以下表格描述了每个后缀的含义
后缀 | 描述 |
all | 包含连接器、MongoDB依赖项和Apache Avro的超集JAR文件 |
confluent | 包含连接器和Confluent平台的最小需求 |
javadoc | 包含连接器类的Javadoc文档 |
sources | 包含与编译的连接器类对应的源代码 |
例如,mongo-kafka-connect-1.14.1-all.jar
是版本1.14.1连接器的超集JAR文件。