如何使用ssl postgres身份验证为postgresql配置kafka connect jdbc接收器连接器？

Question

我有一个使用用户名和密码配置的 postgres 工作 jdbc 接收器连接器配置：

{
    "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
    "connection.url": "jdbc:postgresql://localhost:5432/postgres",
    "connection.user": "postgres-user",
    "connection.password": "postgres-pw",
    "topics.regex": "my-topic",
    "transforms": "unwrap",
    "transforms.unwrap.type": "io.debezium.transforms.ExtractNewRecordState",
    "transforms.unwrap.drop.tombstones": "false",    
    "key.converter": "org.apache.kafka.connect.json.JsonConverter",
    "key.converter.schemas.enable": "false",
    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
    "value.converter.schemas.enable": "false",
    "auto.create": "true",
    "insert.mode": "upsert",
    "auto.evolve": "true",
    "table.name.format" : "${topic}",
    "pk.mode": "record_key",
    "pk.fields": "id",
}

但是我想将相同的连接器连接到使用 ssl 连接的 postgres 服务器，该连接需要用户名、

.cert

文件和

.key

文件。

但是在文档中我只看到

ssl.rootcertfile

配置选项，它与证书和密钥文件不同。

我想知道是否可以在连接器配置中设置

.cert

和

.key

文件？

Answer 1

您需要修改连接网址以添加至少

?ssl=true

https://jdbc.postgresql.org/documentation/use/