我想在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
1条答案
按热度按时间50few1ms1#
我相信你指的是ssl,不是ssh。。。
这里有为mongo设置tls的文档,我不确定debezium是如何处理的,但是我确实看到了
mongodb.ssl.enabled
debezium文档上的属性如果您的字面意思是ssh,那么您可能可以设置一个ssh隧道,到您的数据库1,但这将是kafka connect进程外部的,您可以连接到
127.0.0.1:(tunnel_port)
复制自-如何通过ssh隧道连接到mongodb服务器在每个连接工人上建立隧道。
然后更新连接配置以使用
127.0.0.1:9999
1投诉人:未测试