如何从debezium通过ssh连接到mongodb

af7jpaap 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(421)

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

mongodb apache-kafka apache-kafka-connect debezium ssh

来源：https://stackoverflow.com/questions/54549993/how-to-connect-to-a-mongodb-over-ssh-from-debezium

1条答案

按热度按时间

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投诉人：未测试

赞(0）回复(0）举报 2021-06-07

我来回答

如何从debezium通过ssh连接到mongodb

1条答案

相关问题

热门标签

最新问答