MongoDB Kafka Connector 1.7.0 Docker部署配置报错及副本集疑问

一、选择主题时出现java.lang.NullPointerException的排查方向 #

• 确认插件加载配置：检查Kafka Connect容器的plugin.path环境变量是否正确指向MongoDB Connector的jar包目录，Docker环境下需确保插件目录挂载无误，且jar包拥有可读权限。
• 查看完整错误堆栈：执行docker logs <your-connect-container-id>获取NPE的详细日志，定位空指针触发的具体环节——通常是Connect无法拉取Kafka主题元数据，或连接器插件内部对空值未做处理导致。
• 验证网络连通性：确保Kafka Connect容器能正常访问Kafka集群，Docker环境下若使用自定义网络，需确认Connect容器与Kafka容器在同一网络内，且能解析Kafka的容器名称或IP。

二、mongodb://localhost:27017配置无效的解决方法 #

容器内的localhost指向容器自身，而非宿主机或其他容器，这是核心问题：

• 若MongoDB部署在宿主机：
  • Windows/macOS环境：将connection.uri改为mongodb://host.docker.internal:27017
  • Linux环境：启动Connect容器时添加--add-host host.docker.internal:host-gateway参数，再使用mongodb://host.docker.internal:27017作为连接地址
• 若MongoDB是Docker容器：
  • 确保两者在同一Docker网络中，将connection.uri改为mongodb://<mongo-container-name>:27017（替换为你的MongoDB容器名称）
• 额外必填项检查：配置时需指定database和collection字段；若MongoDB开启了身份验证，还需在uri中加入用户名和密码，格式为mongodb://<username>:<password>@<host>:27017

三、单实例MongoDB是否需要创建副本集？ #

MongoDB Kafka Connector 1.7.0支持单实例MongoDB，无需强制创建副本集，但需在连接器配置中添加mongodb.members.auto.discover=false以禁用自动副本集成员发现。不过生产环境建议使用副本集，以保证数据可靠性和连接器的故障转移能力；开发测试环境单实例可正常使用。

内容的提问来源于stack exchange，提问作者Viji Lakshmi