如何从 Debezium 通过 SSH 连接到 MongoDB答案

【问题标题】：How to connect to a MongoDB over SSH from Debezium如何从 Debezium 通过 SSH 连接到 MongoDB
【发布时间】：2019-06-30 04:36:12
【问题描述】：

我想在我的 Debezium 中通过 ssh 连接到 MongoDB 实例。

与 MongoDB 的连接不需要 ssh，它正在通过，但使用 SSH 我收到超时异常。

我正在使用下面提到的常规 kafka-connect 属性。

name=XYZ 
connector.class=io.debezium.connector.mongodb.MongoDbConnector 
tasks.max=1 
database.list=XXXXXX:27017 
connection.url=xxxx:27017 
mongodb.hosts=xxxx:27017 
mongodb.name=xyz 
collection.whitelist=xyz.collection1 
database.whitelist=xyz 
converter.class=org.apache.kafka.connect.json.JsonConverter 
key.converter=org.apache.kafka.connect.json.JsonConverter 
value.converter=org.apache.kafka.connect.json.JsonConverter 
key.converter.schemas.enable=false 
value.converter.schemas.enable=false

【问题讨论】：

你能分享一下你正在使用的配置吗？
我正在使用如下所述的常规 kafka-connect 属性。 name=XYZ connector.class=io.debezium.connector.mongodb.MongoDbConnector tasks.max=1 database.list=XXXXXX:27017 connection.url=xxxx:27017 mongodb.hosts=xxxx:27017 mongodb.name=xyz collection.whitelist =xyz.collection1 database.whitelist=xyz 转换器.class=org.apache.kafka.connect.json.JsonConverter key.converter=org.apache.kafka.connect.json.JsonConverter value.converter=org.apache.kafka.connect .json.JsonConverter key.converter.schemas.enable=false value.converter.schemas.enable=false
运行Kafka Connect的机器能否与运行MongoDB的机器建立SSH连接？

标签： mongodb ssh apache-kafka apache-kafka-connect debezium

【解决方案1】：

我相信你的意思是 SSL，而不是 SSH...

为 Mongo 设置 TLS 的文档是 here，我不确定 Debezium 是如何处理的，但我确实在 Debezium 文档中看到了 mongodb.ssl.enabled 属性

如果您的字面意思是 SSH，那么您也许可以为您的数据库¹ 设置一个 SSH 隧道，但这将是外部 strong> 到 Kafka Connect 进程，您将连接到 127.0.0.1:(tunnel_port)

复制自 - how to connect to mongodb server via ssh tunnel

在每个连接工作人员上建立隧道。

ssh -fN -l root -i path/to/id_rsa -L 9999:localhost:27017 mongo-host.com

然后更新您的 Connect 配置以使用 127.0.0.1:9999

¹免责声明：未经测试

【讨论】：