Как подключиться к MongoDB через SSH от Debezium - PullRequest
Новая
       65

Как подключиться к MongoDB через SSH от Debezium

0 голосов
/ 06 февраля 2019

Я хочу подключиться к экземпляру mongoDB через ssh в моем Debezium.

Для подключения к 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 Ответ

0 голосов
/ 07 февраля 2019

Полагаю, вы имеете в виду SSL, а не SSH ...

Документация по настройке TLS для Mongo: здесь , и я не совсем уверен, как Debezium справляется с этим, ноЯ вижу свойство mongodb.ssl.enabled в документах Debezium

Если вы буквально имели в виду SSH, то вы можете установить SSH туннель для своей базы данных 1 , но это будет внешний к процессу Kafka Connect, и вы будете подключаться к 127.0.0.1:(tunnel_port)

Скопировано из - как подключиться к серверу mongodb через sshТуннель

Установите туннель на каждого рабочего подключения.

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

Затем обновите конфигурацию Connect, чтобы использовать 127.0.0.1:9999

1 Отказ от ответственности : Не проверено

...