[2021-11-25 06:59:38,473] DEBUG no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:38,542] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:38,542] DEBUG no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:38,973] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:38,973] DEBUG no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,042] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,042] DEBUG polling records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,042] DEBUG no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,474] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,474] DEBUG polling records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,474] DEBUG no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,542] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,542] DEBUG no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,973] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:39,973] DEBUG no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:40,042] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:40,042] DEBUG polling records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:40,042] DEBUG no records available yet, sleeping a bit... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:40,261] WARN Failed to read column metadata for 'public.customer_location' (io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder) [2021-11-25 06:59:40,261] ERROR Producer failure (io.debezium.pipeline.ErrorHandler) org.postgresql.util.PSQLException: This connection has been closed. at org.postgresql.jdbc.PgConnection.checkClosed(PgConnection.java:865) at org.postgresql.jdbc.PgConnection.createStatement(PgConnection.java:1764) at org.postgresql.jdbc.PgDatabaseMetaData.createMetaDataStatement(PgDatabaseMetaData.java:2663) at org.postgresql.jdbc.PgDatabaseMetaData.getPrimaryKeys(PgDatabaseMetaData.java:2156) at io.debezium.jdbc.JdbcConnection.readPrimaryKeyNames(JdbcConnection.java:1286) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.handleRelationMessage(PgOutputMessageDecoder.java:278) 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:188) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:150) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:38) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122) 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) [2021-11-25 06:59:40,262] DEBUG stopping streaming... (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [2021-11-25 06:59:40,262] DEBUG Closing message decoder (io.debezium.connector.postgresql.connection.PostgresReplicationConnection) [2021-11-25 06:59:40,263] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2021-11-25 06:59:40,263] DEBUG Closing replication connection (io.debezium.connector.postgresql.connection.PostgresReplicationConnection) [2021-11-25 06:59:40,265] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2021-11-25 06:59:40,266] INFO Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator) [2021-11-25 06:59:40,266] INFO Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics) [2021-11-25 06:59:40,473] DEBUG checking for more records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:40,473] DEBUG polling records... (io.debezium.connector.base.ChangeEventQueue) [2021-11-25 06:59:40,473] INFO WorkerSourceTask{id=conn_access_pg-0} Committing offsets (org.apache.kafka.connect.runtime.WorkerSourceTask) [2021-11-25 06:59:40,473] INFO WorkerSourceTask{id=conn_access_pg-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask) [2021-11-25 06:59:40,473] DEBUG Streaming has already stopped, ignoring commit callback... (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource) [2021-11-25 06:59:40,473] ERROR WorkerSourceTask{id=conn_access_pg-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (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.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:42) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:153) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:38) at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159) at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122) 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: This connection has been closed. at org.postgresql.jdbc.PgConnection.checkClosed(PgConnection.java:865) at org.postgresql.jdbc.PgConnection.createStatement(PgConnection.java:1764) at org.postgresql.jdbc.PgDatabaseMetaData.createMetaDataStatement(PgDatabaseMetaData.java:2663) at org.postgresql.jdbc.PgDatabaseMetaData.getPrimaryKeys(PgDatabaseMetaData.java:2156) at io.debezium.jdbc.JdbcConnection.readPrimaryKeyNames(JdbcConnection.java:1286) at io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder.handleRelationMessage(PgOutputMessageDecoder.java:278) 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:188) at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:150) ... 8 more [2021-11-25 06:59:40,474] INFO Stopping down connector (io.debezium.connector.common.BaseSourceTask) [2021-11-25 06:59:40,476] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2021-11-25 06:59:40,477] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection) [2021-11-25 06:59:40,477] INFO [Producer clientId=connector-producer-conn_access_pg-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer) [2021-11-25 06:59:40,481] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics) [2021-11-25 06:59:40,481] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics) [2021-11-25 06:59:40,481] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics) [2021-11-25 06:59:40,482] INFO App info kafka.producer for connector-producer-conn_access_pg-0 unregistered (org.apache.kafka.common.utils.AppInfoParser)