[INFO] 2021-11-25 10:28:37,246 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:28:47,258 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:28:57,272 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:29:07,282 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:29:17,293 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [ERROR] 2021-11-25 10:29:25,245 [debezium-postgresconnector-GatewayDepot87-change-event-source-coordinator] io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder getTableColumnsFromDatabase - Failed to read column metadata for 'public.tbeventqueue' [ERROR] 2021-11-25 10:29:25,245 [debezium-postgresconnector-GatewayDepot87-change-event-source-coordinator] io.debezium.pipeline.ErrorHandler setProducerThrowable - Producer failure org.postgresql.util.PSQLException: An I/O error occurred while sending to the backend. at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:349) at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:481) at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:401) at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:322) at org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:308) at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:284) at org.postgresql.jdbc.PgStatement.executeQuery(PgStatement.java:236) at org.postgresql.jdbc.PgDatabaseMetaData.getColumns(PgDatabaseMetaData.java:1579) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.getTableColumnsFromDatabase(PgOutputMessageDecoder.java:333) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.handleRelationMessage(PgOutputMessageDecoder.java:272) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.processNotEmptyMessage(PgOutputMessageDecoder.java:176) at io.debezium.connector.postgresql.connection.AbstractMessageDecoder.processMessage(AbstractMessageDecoder.java:33) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.deserializeMessages(PostgresReplicationConnection.java:493) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:485) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:205) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:167) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:40) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: java.net.SocketException: Connection reset by peer (Write failed) at java.base/java.net.SocketOutputStream.socketWrite0(Native Method) at java.base/java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:110) at java.base/java.net.SocketOutputStream.write(SocketOutputStream.java:150) at java.base/java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81) at java.base/java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142) at org.postgresql.core.PGStream.flush(PGStream.java:665) at org.postgresql.core.v3.QueryExecutorImpl.sendSync(QueryExecutorImpl.java:1469) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:320) ... 23 more [INFO] 2021-11-25 10:29:25,247 [pool-185-thread-1] io.debezium.jdbc.JdbcConnection lambda$doClose$3 - Connection gracefully closed [INFO] 2021-11-25 10:29:25,251 [pool-186-thread-1] io.debezium.jdbc.JdbcConnection lambda$doClose$3 - Connection gracefully closed [INFO] 2021-11-25 10:29:25,252 [debezium-postgresconnector-GatewayDepot87-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator streamEvents - Finished streaming [INFO] 2021-11-25 10:29:25,252 [debezium-postgresconnector-GatewayDepot87-change-event-source-coordinator] io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics connected - Connected metrics set to 'false' [INFO] 2021-11-25 10:29:25,563 [task-thread-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [ERROR] 2021-11-25 10:29:25,575 [task-thread-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] org.apache.kafka.connect.runtime.WorkerTask doRun - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted org.apache.kafka.connect.errors.ConnectException: An exception occurred in the change event producer. This connector will be stopped. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:170) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:40) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:166) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:127) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: org.postgresql.util.PSQLException: An I/O error occurred while sending to the backend. at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:349) at org.postgresql.jdbc.PgStatement.executeInternal(PgStatement.java:481) at org.postgresql.jdbc.PgStatement.execute(PgStatement.java:401) at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:322) at org.postgresql.jdbc.PgStatement.executeCachedSql(PgStatement.java:308) at org.postgresql.jdbc.PgStatement.executeWithFlags(PgStatement.java:284) at org.postgresql.jdbc.PgStatement.executeQuery(PgStatement.java:236) at org.postgresql.jdbc.PgDatabaseMetaData.getColumns(PgDatabaseMetaData.java:1579) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.getTableColumnsFromDatabase(PgOutputMessageDecoder.java:333) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.handleRelationMessage(PgOutputMessageDecoder.java:272) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.processNotEmptyMessage(PgOutputMessageDecoder.java:176) at io.debezium.connector.postgresql.connection.AbstractMessageDecoder.processMessage(AbstractMessageDecoder.java:33) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.deserializeMessages(PostgresReplicationConnection.java:493) at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:485) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:205) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:167) ... 8 more Caused by: java.net.SocketException: Connection reset by peer (Write failed) at java.base/java.net.SocketOutputStream.socketWrite0(Native Method) at java.base/java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:110) at java.base/java.net.SocketOutputStream.write(SocketOutputStream.java:150) at java.base/java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81) at java.base/java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142) at org.postgresql.core.PGStream.flush(PGStream.java:665) at org.postgresql.core.v3.QueryExecutorImpl.sendSync(QueryExecutorImpl.java:1469) at org.postgresql.core.v3.QueryExecutorImpl.execute(QueryExecutorImpl.java:320) ... 23 more [INFO] 2021-11-25 10:29:25,576 [task-thread-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] io.debezium.connector.common.BaseSourceTask stop - Stopping down connector [INFO] 2021-11-25 10:29:25,580 [pool-187-thread-1] io.debezium.jdbc.JdbcConnection lambda$doClose$3 - Connection gracefully closed [INFO] 2021-11-25 10:29:25,581 [pool-188-thread-1] io.debezium.jdbc.JdbcConnection lambda$doClose$3 - Connection gracefully closed [INFO] 2021-11-25 10:29:25,582 [task-thread-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] org.apache.kafka.clients.producer.KafkaProducer close - [Producer clientId=connector-producer-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] Closing the Kafka producer with timeoutMillis = 30000 ms. [INFO] 2021-11-25 10:29:25,584 [kafka-expiring-relogin-thread-kafkatestpmops-proxy] org.apache.kafka.common.security.oauthbearer.internals.expiring.ExpiringCredentialRefreshingLogin run - [Principal=:kafkatestpmops-proxy]: Expiring credential re-login thread has been interrupted and will exit. [INFO] 2021-11-25 10:29:25,584 [task-thread-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] org.apache.kafka.common.metrics.Metrics close - Metrics scheduler closed [INFO] 2021-11-25 10:29:25,585 [task-thread-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] org.apache.kafka.common.metrics.Metrics close - Closing reporter org.apache.kafka.common.metrics.JmxReporter [INFO] 2021-11-25 10:29:25,585 [task-thread-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] org.apache.kafka.common.metrics.Metrics close - Metrics reporters closed [INFO] 2021-11-25 10:29:25,585 [task-thread-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0] org.apache.kafka.common.utils.AppInfoParser unregisterAppInfo - App info kafka.producer for connector-producer-itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0 unregistered [INFO] 2021-11-25 10:29:27,306 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:29:37,306 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:29:47,307 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:29:57,307 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:30:07,307 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:30:17,308 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:30:27,308 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:30:37,309 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:30:47,309 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:30:57,309 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit [INFO] 2021-11-25 10:31:07,309 [SourceTaskOffsetCommitter-1] org.apache.kafka.connect.runtime.WorkerSourceTask commitOffsets - WorkerSourceTask{id=itgermany.pmops.dispoapp.gateway.DE-870.debeziumconnector-0} flushing 0 outstanding messages for offset commit