we are trying to upgrade debezium-connector-sqlserver-1.0.0. to debezium-connector-sqlserver-1.9.5..After upgrade ,the debezium connector status api always shows running status ,even if connector has exception.the server has adopt open jdk 8.
[2022-08-26 11:20:10,668] ERROR Producer failure (io.debezium.pipeline.ErrorHandler)
com.microsoft.sqlserver.jdbc.SQLServerException: The TCP/IP connection to the host testserver, port 1433 has failed. Error: "testserver. Verify the connection properties. Make sure that an instance of SQL Server is running on the host and accepting TCP/IP connections at the port. Make sure that TCP connections to the port are not blocked by a firewall.".
at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDriverError(SQLServerException.java:237)
at com.microsoft.sqlserver.jdbc.SQLServerException.ConvertConnectExceptionToSQLServerException(SQLServerException.java:288)
at com.microsoft.sqlserver.jdbc.SocketFinder.findSocket(IOBuffer.java:2466)
at com.microsoft.sqlserver.jdbc.TDSChannel.open(IOBuffer.java:676)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.connectHelper(SQLServerConnection.java:2957)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.login(SQLServerConnection.java:2628)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.connectInternal(SQLServerConnection.java:2471)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.connect(SQLServerConnection.java:1470)
at com.microsoft.sqlserver.jdbc.SQLServerDriver.connect(SQLServerDriver.java:915)
at io.debezium.jdbc.JdbcConnection.lambda$patternBasedFactory$1(JdbcConnection.java:243)
at io.debezium.jdbc.JdbcConnection$ConnectionFactoryDecorator.connect(JdbcConnection.java:128)
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:882)
at io.debezium.connector.sqlserver.SqlServerConnection.connection(SqlServerConnection.java:221)
at io.debezium.jdbc.JdbcConnection.connection(JdbcConnection.java:877)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:630)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:504)
at io.debezium.connector.sqlserver.SqlServerConnection.getMaxTransactionLsn(SqlServerConnection.java:274)
at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.getToLsn(SqlServerStreamingChangeEventSource.java:439)
at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.executeIteration(SqlServerStreamingChangeEventSource.java:153)
at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.executeIteration(SqlServerStreamingChangeEventSource.java:59)
at io.debezium.connector.sqlserver.SqlServerChangeEventSourceCoordinator.executeChangeEventSources(SqlServerChangeEventSourceCoordinator.java:98)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
[2022-08-26 11:20:10,716] WARN Going to restart connector after 10 sec. after a retriable exception (io.debezium.connector.common.BaseSourceTask)
But the connector status api is showing running status. {"name":"sql-connector-4","connector":{"state":"RUNNING","worker_id":"192.168.115.98:8083"},"tasks":[{"id":0,"state":"RUNNING","worker_id":"192.168.115.98:8083"}],"type":"source"}
my connector configuration:
{
"name": "sql-connector-4",
"config": {
"name": "sql-connector-4",
"connector.class": "io.debezium.connector.sqlserver.SqlServerConnector",
"database.hostname": "testserver",
"database.port": "1433",
"database.user": "sa",
"database.password": "test@123",
"database.server.id": "219",
"database.server.name": "testserver",
"database.dbname": "kafkaTesting",
"table.whitelist": "dbo.testtable",
"database.history.kafka.bootstrap.servers": "serverip:9092",
"database.history.kafka.topic": "dbhistory.demo",
"include.schema.changes": "true",
"errors.retry.timeout":1,
"errors.retry.delay.max.ms":1000
} }