Kafka 连接器教程设置
本节中的教程在一个使用 Docker 打包运行 MongoDB 连接器所需的依赖项和配置的开发环境中运行。在继续教程之前，请确保您已完成开发环境设置步骤。
需求
创建或登录您的Docker账户以下载本教程所需的Docker容器。要了解如何注册账户和安装Docker Desktop，请阅读Docker Hub快速入门中的注册和下载步骤。Docker Hub 快速入门.
终端应用程序和shell。对于MacOS用户，请使用Terminal或类似的应用程序。对于Windows用户，请使用PowerShell。
可选。安装git以下载设置文件。要了解如何安装git，请阅读Git 下载页面。
使用Docker设置您的开发环境
克隆或下载教程仓库
接下来，使用以下命令克隆教程 git 仓库
git clone https://github.com/mongodb-university/kafka-edu.git
如果您没有安装 git，您可以下载 zip 压缩包 作为替代。
运行开发环境
选择与您的操作系统匹配的选项卡，获取在此指南中运行命令的说明
使用 bash shell 切换到仓库或解压归档中的 "mongodb-kafka-base" 教程目录。如果您使用 git 克隆了仓库，您的命令类似于以下内容
cd kafka-edu/docs-examples/mongodb-kafka-base/
使用 PowerShell 切换到仓库或解压归档中的 "mongodb-kafka-base" 教程目录。如果您使用 git 克隆了仓库，您的命令类似于以下内容
cd kafka-edu\docs-examples\mongodb-kafka-base\
使用以下命令启动Docker镜像
docker-compose -p mongo-kafka up -d --force-recreate
注意
端口映射
沙盒将以下服务映射到主机的端口
沙盒MongoDB服务器映射到端口
35001在您的主机上沙盒Kafka Connect JMX服务器映射到端口
35000在您的主机上
这些端口必须空闲才能启动沙盒。
"mongo-kafka-base"镜像创建了一个Docker容器，该容器包含了教程中所需的全部服务，并在名为"mongodb-kafka-base_localnet"的共享网络上运行，如下图所示
命令成功完成后，将输出以下文本
... Creating zookeeper ... done Creating broker ... done Creating schema-registry ... done Creating connect ... done Creating rest-proxy ... done Creating mongo1 ... done Creating mongo1-setup ... done
验证成功设置
通过运行以下命令确认开发环境已成功启动
docker exec mongo1 status
如果Docker开发环境成功设置，此命令应输出以下信息
Kafka topics: "topic": "docker-connect-status", "topic": "docker-connect-offsets", "topic": "docker-connect-configs", "topic": "__consumer_offsets", The status of the connectors: Currently configured connectors [] Version of MongoDB Connector for Apache Kafka installed: {"class":"com.mongodb.kafka.connect.MongoSinkConnector","type":"sink","version":"1.8.0"} {"class":"com.mongodb.kafka.connect.MongoSourceConnector","type":"source","version":"1.8.0"}
由于您尚未启动连接器，状态和配置列表为空。
您的开发环境设置已完成，您可以继续教程的下一步。
提示
连接到开发环境MongoDB
您可以使用以下连接字符串连接到在开发环境中运行的MongoDB集群
mongodb://localhost:35001/?directConnection=true