在启用cdc功能后尝试将debezium连接到sql server数据库时,出现以下错误消息:
java.lang.RuntimeException: Couldn't obtain database name,
at io.debezium.connector.sqlserver.SqlServerConnection.retrieveRealDatabaseName(SqlServerConnection.java:364),
at io.debezium.connector.sqlserver.SqlServerConnection.<init>(SqlServerConnection.java:84),
at io.debezium.connector.sqlserver.SqlServerConnectorTask.start(SqlServerConnectorTask.java:86),
at io.debezium.connector.common.BaseSourceTask.start(BaseSourceTask.java:47),
at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:198),
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:175),
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:219),
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511),
at java.util.concurrent.FutureTask.run(FutureTask.java:266),
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149),
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624),
at java.lang.Thread.run(Thread.java:748),
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: The driver could not establish a secure connection to SQL Server by using Secure Sockets Layer (SSL) encryption. Error: "SQL Server did not return a response. The connection has been closed. ClientConnectionId:bce7b974-bac3-4068-b85f-271ba41295e4".,
at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2670),
at com.microsoft.sqlserver.jdbc.TDSChannel.enableSSL(IOBuffer.java:1837),
at com.microsoft.sqlserver.jdbc.SQLServerConnection.connectHelper(SQLServerConnection.java:2257),
at com.microsoft.sqlserver.jdbc.SQLServerConnection.login(SQLServerConnection.java:1921),
at com.microsoft.sqlserver.jdbc.SQLServerConnection.connectInternal(SQLServerConnection.java:1762),
at com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(SQLServerConnection.java:1077),
at com.microsoft.sqlserver.jdbc.SQLServerDriver.connect(SQLServerDriver.java:623),
at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:179),
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:734),
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:729),
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:516),
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:391),
at io.debezium.connector.sqlserver.SqlServerConnection.retrieveRealDatabaseName(SqlServerConnection.java:358),
... 11 more,
Caused by: java.io.IOException: SQL Server did not return a response. The connection has been closed. ClientConnectionId:bce7b974-bac3-4068-b85f-271ba41295e4,
at com.microsoft.sqlserver.jdbc.TDSChannel$SSLHandshakeInputStream.ensureSSLPayload(IOBuffer.java:780),
at com.microsoft.sqlserver.jdbc.TDSChannel$SSLHandshakeInputStream.readInternal(IOBuffer.java:836),
at com.microsoft.sqlserver.jdbc.TDSChannel$SSLHandshakeInputStream.read(IOBuffer.java:827),
at com.microsoft.sqlserver.jdbc.TDSChannel$ProxyInputStream.readInternal(IOBuffer.java:1009),
at com.microsoft.sqlserver.jdbc.TDSChannel$ProxyInputStream.read(IOBuffer.java:997),
at sun.security.ssl.InputRecord.readFully(InputRecord.java:465),
at sun.security.ssl.InputRecord.read(InputRecord.java:503),
at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:975),
at sun.security.ssl.SSLSocketImpl.performInitialHandshake(SSLSocketImpl.java:1367),
at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:1395),
at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:1379),
at com.microsoft.sqlserver.jdbc.TDSChannel.enableSSL(IOBuffer.java:1767),
... 22 more,
以下是我的连接器配置:
curl -i -X POST -H "Accept:application/json" -H "Content-Type:application/json" localhost:8083/connectors/ -d '{ "name": "sql-connector",
"config": {
"connector.class": "io.debezium.connector.sqlserver.SqlServerConnector",
"database.hostname": "XXX.XXX.XXX.XXX",
"database.port": "1433",
"database.user": "login",
"database.password": "password",
"database.dbname": "BDNAME",
"database.server.name": "bdservername",
"table.whitelist": "bdSchema.TABLE",
"database.history.kafka.bootstrap.servers": "kafka:9092",
"database.history.kafka.topic": "dbhistory.TABLE" }
}'
我在这里找到了一个解决方法:
https://github.com/microsoft/mssql-jdbc/issues/879#issuecomment-438825486
但有没有可能把它用在debezium连接器上?debezium是否与sql server 2008 r2兼容,因为在文档中它是这样写的:
The functionality of the connector is based upon change data capture feature provided by SQL Server Standard (since SQL Server 2016 SP1) or Enterprise edition
作为参考,我使用了debezium docker images 0.9.2:-debezium/zookeeper-debezium/kafka-debezium/connect
事先谢谢你的帮助。
sé巴斯蒂安
1条答案
按热度按时间s3fp2yjn1#
我在激活tls调试模式时发现了这个问题。
所以我看到Java8默认使用TLSV1.2,即使我将任何tls选项设置为jdbc连接属性。
当我尝试用Java7连接到SQLServer时,它成功了。经过一番搜索,我发现这是因为Java7使用了这个tls算法:3des\u ede\u cbc。
解决方法是删除值
3DES_EDE_CBC
放入java.security文件中jdk.tls.disabledAlgorithms
钥匙。现在debezium可以连接到我的sql服务器了!
别担心,我不是在使用生产平台;-)