2020-03-26 21:32:05,079 INFO   ||  WorkerSourceTask{id=mediarelated-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,335 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,336 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,334 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,336 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,334 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,337 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,334 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,337 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,334 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,338 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,334 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,339 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,339 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,339 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,340 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,340 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,340 ERROR  ||  Producer failure   [io.debezium.pipeline.ErrorHandler]
com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        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:834)
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,341 INFO   ||  Creating thread debezium-sqlserverconnector-azure-error-handler   [io.debezium.util.Threads]
2020-03-26 21:32:05,354 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,354 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,355 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,355 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,355 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,355 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,356 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,356 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,356 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,356 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,357 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,357 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,357 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,357 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,358 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,358 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,358 INFO   ||  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,360 INFO   ||  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2020-03-26 21:32:05,360 INFO   ||  WorkerSourceTask{id=logbookmark-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,361 INFO   ||  WorkerSourceTask{id=logbookmark-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,361 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,361 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,361 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,362 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,362 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,362 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,362 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,363 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,363 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,363 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,363 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,363 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,363 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,361 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,365 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,363 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,365 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,365 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,361 ERROR  ||  WorkerSourceTask{id=logbookmark-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,366 ERROR  ||  WorkerSourceTask{id=logbookmark-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,366 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,366 INFO   ||  [Producer clientId=connector-producer-logbookmark-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,363 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,370 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,370 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,362 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,371 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,372 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,371 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=snapshot,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,385 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=streaming,server=azure'   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2020-03-26 21:32:05,385 ERROR  ||  Interrupted while stopping   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
java.lang.InterruptedException
        at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2109)
        at java.base/java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1454)
        at java.base/java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:709)
        at io.debezium.pipeline.ErrorHandler.stop(ErrorHandler.java:52)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:206)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,386 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,387 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,387 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,387 ERROR  ||  [Producer clientId=azure-dbhistory] Interrupted while joining ioThread   [org.apache.kafka.clients.producer.KafkaProducer]
java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,390 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
2020-03-26 21:32:05,387 ERROR  ||  [Producer clientId=azure-dbhistory] Interrupted while joining ioThread   [org.apache.kafka.clients.producer.KafkaProducer]
java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,392 INFO   ||  [Producer clientId=azure-dbhistory] Proceeding to force close the producer since pending requests could not be completed within timeout 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,388 ERROR  ||  [Producer clientId=azure-dbhistory] Interrupted while joining ioThread   [org.apache.kafka.clients.producer.KafkaProducer]
java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
Exception in thread "debezium-sqlserverconnector-azure-error-handler" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
2020-03-26 21:32:05,393 INFO   ||  WorkerSourceTask{id=logmedia-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,393 INFO   ||  WorkerSourceTask{id=logmedia-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1201)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
2020-03-26 21:32:05,393 ERROR  ||  WorkerSourceTask{id=logmedia-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,394 ERROR  ||  WorkerSourceTask{id=logmedia-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,394 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,394 INFO   ||  [Producer clientId=connector-producer-logmedia-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
2020-03-26 21:32:05,395 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
2020-03-26 21:32:05,395 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
Caused by: java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
2020-03-26 21:32:05,397 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        ... 9 more
Exception in thread "debezium-sqlserverconnector-azure-error-handler" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1201)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,404 ERROR  ||  [Producer clientId=azure-dbhistory] Interrupted while joining ioThread   [org.apache.kafka.clients.producer.KafkaProducer]
java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
Caused by: java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,404 INFO   ||  [Producer clientId=azure-dbhistory] Proceeding to force close the producer since pending requests could not be completed within timeout 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,404 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
        ... 9 more
Exception in thread "debezium-sqlserverconnector-azure-error-handler" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1201)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
2020-03-26 21:32:05,407 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
        at java.base/java.lang.Thread.run(Thread.java:834)
2020-03-26 21:32:05,408 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
Caused by: java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        ... 9 more
Exception in thread "debezium-sqlserverconnector-azure-error-handler" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
2020-03-26 21:32:05,408 ERROR  ||  [Producer clientId=azure-dbhistory] Interrupted while joining ioThread   [org.apache.kafka.clients.producer.KafkaProducer]
java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,409 INFO   ||  [Producer clientId=azure-dbhistory] Proceeding to force close the producer since pending requests could not be completed within timeout 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1201)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
2020-03-26 21:32:05,408 ERROR  ||  [Producer clientId=azure-dbhistory] Interrupted while joining ioThread   [org.apache.kafka.clients.producer.KafkaProducer]
java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
2020-03-26 21:32:05,410 INFO   ||  [Producer clientId=azure-dbhistory] Proceeding to force close the producer since pending requests could not be completed within timeout 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
Caused by: java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        ... 9 more
2020-03-26 21:32:05,414 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
2020-03-26 21:32:05,414 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
Exception in thread "debezium-sqlserverconnector-azure-error-handler" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1201)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
Caused by: java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        ... 9 more
Exception in thread "debezium-sqlserverconnector-azure-error-handler" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1201)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
Caused by: java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        ... 9 more
2020-03-26 21:32:05,422 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,425 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,425 ERROR  ||  [Producer clientId=azure-dbhistory] Interrupted while joining ioThread   [org.apache.kafka.clients.producer.KafkaProducer]
java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,425 INFO   ||  [Producer clientId=azure-dbhistory] Proceeding to force close the producer since pending requests could not be completed within timeout 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,426 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
Exception in thread "debezium-sqlserverconnector-azure-error-handler" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1201)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
Caused by: java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        ... 9 more
2020-03-26 21:32:05,427 INFO   ||  [Producer clientId=azure-dbhistory] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,429 ERROR  ||  [Producer clientId=azure-dbhistory] Interrupted while joining ioThread   [org.apache.kafka.clients.producer.KafkaProducer]
java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
2020-03-26 21:32:05,430 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
2020-03-26 21:32:05,430 ERROR  ||  Unable to unregister the MBean 'debezium.sql_server:type=connector-metrics,context=schema-history,server=azure'   [io.debezium.relational.history.DatabaseHistoryMetrics]
Exception in thread "debezium-sqlserverconnector-azure-error-handler" org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1201)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1176)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1154)
        at io.debezium.relational.history.KafkaDatabaseHistory.stop(KafkaDatabaseHistory.java:325)
        at io.debezium.relational.HistorizedRelationalDatabaseSchema.close(HistorizedRelationalDatabaseSchema.java:53)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.cleanupResources(SqlServerConnectorTask.java:233)
        at io.debezium.pipeline.ErrorHandler.lambda$setProducerThrowable$0(ErrorHandler.java:42)
        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:834)
Caused by: java.lang.InterruptedException
        at java.base/java.lang.Object.wait(Native Method)
        at java.base/java.lang.Thread.join(Thread.java:1313)
        at org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:1199)
        ... 9 more
2020-03-26 21:32:05,756 INFO   ||  WorkerSourceTask{id=user-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,756 INFO   ||  WorkerSourceTask{id=user-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,756 ERROR  ||  WorkerSourceTask{id=user-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,757 ERROR  ||  WorkerSourceTask{id=user-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,757 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,757 INFO   ||  [Producer clientId=connector-producer-user-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,762 INFO   ||  WorkerSourceTask{id=unit-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,762 INFO   ||  WorkerSourceTask{id=unit-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,762 ERROR  ||  WorkerSourceTask{id=unit-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,762 ERROR  ||  WorkerSourceTask{id=unit-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,762 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,762 INFO   ||  [Producer clientId=connector-producer-unit-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,768 INFO   ||  WorkerSourceTask{id=event-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,768 INFO   ||  WorkerSourceTask{id=event-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,768 ERROR  ||  WorkerSourceTask{id=event-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,769 ERROR  ||  WorkerSourceTask{id=event-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,769 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,769 INFO   ||  [Producer clientId=connector-producer-event-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,774 INFO   ||  WorkerSourceTask{id=serverconfig-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,774 INFO   ||  WorkerSourceTask{id=serverconfig-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,774 ERROR  ||  WorkerSourceTask{id=serverconfig-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,775 ERROR  ||  WorkerSourceTask{id=serverconfig-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,775 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,775 INFO   ||  [Producer clientId=connector-producer-serverconfig-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,779 INFO   ||  WorkerSourceTask{id=medialocation-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,779 INFO   ||  WorkerSourceTask{id=medialocation-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,779 ERROR  ||  WorkerSourceTask{id=medialocation-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,780 ERROR  ||  WorkerSourceTask{id=medialocation-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,780 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,780 INFO   ||  [Producer clientId=connector-producer-medialocation-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,784 INFO   ||  WorkerSourceTask{id=mediarelated-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,784 INFO   ||  WorkerSourceTask{id=mediarelated-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,785 ERROR  ||  WorkerSourceTask{id=mediarelated-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,785 ERROR  ||  WorkerSourceTask{id=mediarelated-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,786 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,786 INFO   ||  [Producer clientId=connector-producer-mediarelated-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:05,820 INFO   ||  WorkerSourceTask{id=mediaconfig-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,820 INFO   ||  WorkerSourceTask{id=mediaconfig-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:05,820 ERROR  ||  WorkerSourceTask{id=mediaconfig-cc-events-I-0} Task threw an uncaught and unrecoverable exception   [org.apache.kafka.connect.runtime.WorkerTask]
org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped.
        at io.debezium.connector.base.ChangeEventQueue.throwProducerFailureIfPresent(ChangeEventQueue.java:171)
        at io.debezium.connector.base.ChangeEventQueue.poll(ChangeEventQueue.java:151)
        at io.debezium.connector.sqlserver.SqlServerConnectorTask.poll(SqlServerConnectorTask.java:162)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:265)
        at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:232)
        at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177)
        at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227)
        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:834)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Connection timed out (Read failed)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.terminate(SQLServerConnection.java:2892)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2031)
        at com.microsoft.sqlserver.jdbc.TDSReader.readPacket(IOBuffer.java:6418)
        at com.microsoft.sqlserver.jdbc.TDSCommand.startResponse(IOBuffer.java:7579)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.doExecuteStatement(SQLServerStatement.java:866)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement$StmtExecCmd.doExecute(SQLServerStatement.java:768)
        at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:7194)
        at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:2935)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:248)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:223)
        at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeQuery(SQLServerStatement.java:693)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:539)
        at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:408)
        at io.debezium.connector.sqlserver.SqlServerConnection.getMaxLsn(SqlServerConnection.java:119)
        at io.debezium.connector.sqlserver.SqlServerStreamingChangeEventSource.execute(SqlServerStreamingChangeEventSource.java:124)
        at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:99)
        ... 5 more
Caused by: java.net.SocketException: Connection timed out (Read failed)
        at java.base/java.net.SocketInputStream.socketRead0(Native Method)
        at java.base/java.net.SocketInputStream.socketRead(SocketInputStream.java:115)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:168)
        at java.base/java.net.SocketInputStream.read(SocketInputStream.java:140)
        at com.microsoft.sqlserver.jdbc.TDSChannel.read(IOBuffer.java:2023)
        ... 19 more
2020-03-26 21:32:05,821 ERROR  ||  WorkerSourceTask{id=mediaconfig-cc-events-I-0} Task is being killed and will not recover until manually restarted   [org.apache.kafka.connect.runtime.WorkerTask]
2020-03-26 21:32:05,822 INFO   ||  Connector has already been stopped   [io.debezium.connector.sqlserver.SqlServerConnectorTask]
2020-03-26 21:32:05,822 INFO   ||  [Producer clientId=connector-producer-mediaconfig-cc-events-I-0] Closing the Kafka producer with timeoutMillis = 30000 ms.   [org.apache.kafka.clients.producer.KafkaProducer]
2020-03-26 21:32:13,765 INFO   ||  WorkerSourceTask{id=mediaconfig-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:13,766 INFO   ||  WorkerSourceTask{id=mediaconfig-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:13,766 INFO   ||  WorkerSourceTask{id=logbookmark-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:13,766 INFO   ||  WorkerSourceTask{id=logbookmark-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:13,767 INFO   ||  WorkerSourceTask{id=logmedia-cc-events-I-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2020-03-26 21:32:13,768 INFO   ||  WorkerSourceTask{id=logmedia-cc-events-I-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]