Kafka 连接 SqlServer 配置（SSL）

Question

我有一个 JdbcSourceConnector 连接器，它尝试使用 url“encrypt=false;trustServerCertificate=false;”中的下一个配置来连接到 SQL Server 数据库。因为它是旧版本并且需要连接。

我意识到这只能通过在我的 docker 容器 shell 上执行

update-crypto-policies --set LEGACY

来实现，但现在我在整个 Kafka 生态系统中使用 SSL 迁移到生产环境，上述命令会影响安全性，并且不会离开连接，甚至不会看到代理，而不仅仅是影响连接器或驱动程序（这发生在命令执行之后，在此之前一切正常）。

我只是在想如何克服这些问题。有什么建议吗？也许配置我的 docker 容器的 Java 基础镜像？欢迎所有建议。

{
    "name": "ssqlsource",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
        "tasks.max": "1",
        "connection.url": "jdbc:sqlserver://mydb:1433;databaseName=user;encrypt=false;trustServerCertificate=false;",
        "connection.user": "user",
        "connection.password": "password",
        "mode": "timestamp",
        "timestamp.column.name": "addDate",  
        "topic.prefix": "sn_user",
        "table.whitelist": "user.dbo.sn_user",
        "schema.history.internal.kafka.bootstrap.servers": "kafka:9092",
        "schema.history.internal.kafka.topic": "schema-changes.user",
        "transforms": "route",
        "transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter",
        "transforms.route.regex": "([^.]+)\\.([^.]+)\\.([^.]+)",
        "transforms.route.replacement": "$3"
    }
}

问候， 里戈贝尔托 C.

Answer 1

生产中的问题是证书与我的 JdbcSourceConfig 配置中使用的主机不匹配。如果它们匹配，您将能够使用

 update-crypto-policies --set LEGACY

注意。不要忘记注意安全性，最好使用不同的方法来处理这种情况，而不是我正在应用的方法。 并且还要正确设置您的记录器级别，因为我的记录器配置不正确，这就是我之前没有发现错误的原因。

问候，