如何从debezium通过ssh连接到mongodb

af7jpaap  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(483)

我想在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
50few1ms

50few1ms1#

我相信你指的是ssl,不是ssh。。。
这里有为mongo设置tls的文档,我不确定debezium是如何处理的,但是我确实看到了 mongodb.ssl.enabled debezium文档上的属性
如果您的字面意思是ssh,那么您可能可以设置一个ssh隧道,到您的数据库1,但这将是kafka connect进程外部的,您可以连接到 127.0.0.1:(tunnel_port) 复制自-如何通过ssh隧道连接到mongodb服务器
在每个连接工人上建立隧道。

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

然后更新连接配置以使用 127.0.0.1:9999 1投诉人:未测试

相关问题