0

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
4

1 に答える 1

0

SSHではなくSSLを意味していると思います...

Mongo に TLS をセットアップするためのドキュメントはこちらにあります。Debezium がそれをどのように処理するかはすぐにはわかりませんがmongodb.ssl.enabled、Debezium ドキュメントにプロパティが表示されます。

文字通り SSH を意味する場合は、データベース1への SSHトンネルをセットアップできる可能性がありますが、これは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

次に、Connect構成を更新して使用します127.0.0.1:9999

1免責事項: テストされていません

于 2019-02-07T17:35:12.673 に答える