2021-09-21T21:59:04.731000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 21:59:04,731 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T21:59:04.731000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 21:59:04,731 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T21:59:04.733000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 21:59:04,732 INFO   ||  WorkerSourceTask{id=user-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T21:59:07.602000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 21:59:07,601 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T21:59:07.602000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 21:59:07,602 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T21:59:07.602000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 21:59:07,602 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 0 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:00:04.734000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:00:04,733 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:00:04.734000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:00:04,734 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:00:04.736000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:00:04,736 INFO   ||  WorkerSourceTask{id=user-0} Finished commitOffsets successfully in 2 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:00:07.603000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:00:07,603 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:00:07.603000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:00:07,603 INFO   ||  WorkerSourceTask{id=jax-0} flushing 94 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:00:07.613000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:00:07,613 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 10 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:00:13.415000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:00:13,415 WARN   Postgres|prod|streaming  Primary keys are not defined for table 'placement_video_seen', defaulting to unique indices   [io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder]
2021-09-21T22:01:04.737000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:04,737 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:01:04.737000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:04,737 INFO   ||  WorkerSourceTask{id=user-0} flushing 83 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:01:04.762000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:04,762 INFO   ||  WorkerSourceTask{id=user-0} Finished commitOffsets successfully in 25 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:01:07.613000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:07,613 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:01:07.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:07,614 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:01:07.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:07,614 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:01:20.888000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:20,888 WARN   Postgres|prod|streaming  Primary keys are not defined for table 'placement_video_seen', defaulting to unique indices   [io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder]
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:58,648 ERROR  Postgres|prod|streaming  Producer failure   [io.debezium.pipeline.ErrorHandler]
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 org.postgresql.util.PSQLException: Database connection failed when reading from copy
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1102)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:42)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:158)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:123)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:80)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:473)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:188)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:150)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:38)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.lang.Thread.run(Thread.java:834)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 Caused by: java.net.SocketException: Socket is closed
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.net.Socket.setSoTimeout(Socket.java:1155)
2021-09-21T22:01:58.651000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/sun.security.ssl.BaseSSLSocketImpl.setSoTimeout(BaseSSLSocketImpl.java:639)
2021-09-21T22:01:58.655000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/sun.security.ssl.SSLSocketImpl.setSoTimeout(SSLSocketImpl.java:74)
2021-09-21T22:01:58.655000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.PGStream.hasMessagePending(PGStream.java:148)
2021-09-21T22:01:58.655000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1144)
2021-09-21T22:01:58.655000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1100)
2021-09-21T22:01:58.655000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	... 15 more
2021-09-21T22:01:58.660000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:58,660 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:01:58.662000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:58,662 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:01:58.662000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:58,662 INFO   Postgres|prod|streaming  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:01:58.662000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:58,662 INFO   Postgres|prod|streaming  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2021-09-21T22:01:59.019000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:59,018 WARN   ||  Going to restart connector after 10 sec. after a retriable exception   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:01:59.021000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:59,020 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:01:59.024000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:59,024 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:59,026 WARN   ||  WorkerSourceTask{id=user-0} failed to poll records from SourceTask. Will retry operation.   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted.
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:38)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:153)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:38)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.lang.Thread.run(Thread.java:834)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 Caused by: org.postgresql.util.PSQLException: Database connection failed when reading from copy
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1102)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.CopyDualImpl.readFromCopy(CopyDualImpl.java:42)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.receiveNextData(V3PGReplicationStream.java:158)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:123)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:80)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:473)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:188)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:150)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	... 8 more
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 Caused by: java.net.SocketException: Socket is closed
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.net.Socket.setSoTimeout(Socket.java:1155)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/sun.security.ssl.BaseSSLSocketImpl.setSoTimeout(BaseSSLSocketImpl.java:639)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/sun.security.ssl.SSLSocketImpl.setSoTimeout(SSLSocketImpl.java:74)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.PGStream.hasMessagePending(PGStream.java:148)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.processCopyResults(QueryExecutorImpl.java:1144)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.readFromCopy(QueryExecutorImpl.java:1100)
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	... 15 more
2021-09-21T22:01:59.026000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:01:59,026 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:01.027000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:01,027 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:03.027000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:03,027 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:04.763000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:04,763 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:02:04.763000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:04,763 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:02:04.764000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:04,764 INFO   ||  WorkerSourceTask{id=user-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:02:05.027000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,027 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,327 ERROR  Postgres|prod|streaming  Producer failure   [io.debezium.pipeline.ErrorHandler]
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 org.postgresql.util.PSQLException: Database connection failed when writing to copy
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.flushCopy(QueryExecutorImpl.java:1080)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.CopyDualImpl.flushCopy(CopyDualImpl.java:28)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.updateStatusInternal(V3PGReplicationStream.java:193)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.timeUpdateStatus(V3PGReplicationStream.java:184)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:126)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:80)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:473)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:188)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:150)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:38)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.lang.Thread.run(Thread.java:834)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 Caused by: java.net.SocketException: Connection or outbound has closed
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/sun.security.ssl.SSLSocketImpl$AppOutputStream.write(SSLSocketImpl.java:1190)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.PGStream.flush(PGStream.java:592)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.flushCopy(QueryExecutorImpl.java:1078)
2021-09-21T22:02:05.327000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	... 16 more
2021-09-21T22:02:05.328000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,328 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:02:05.329000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,329 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:02:05.329000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,329 INFO   Postgres|prod|streaming  Finished streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:05.329000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,329 INFO   Postgres|prod|streaming  Connected metrics set to 'false'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2021-09-21T22:02:05.520000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,520 WARN   ||  Going to restart connector after 10 sec. after a retriable exception   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:05.521000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,521 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,522 INFO   ||  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,522 WARN   ||  WorkerSourceTask{id=jax-0} failed to poll records from SourceTask. Will retry operation.   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted.
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:38)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:153)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:38)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:159)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:122)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.lang.Thread.run(Thread.java:834)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 Caused by: org.postgresql.util.PSQLException: Database connection failed when writing to copy
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.flushCopy(QueryExecutorImpl.java:1080)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.CopyDualImpl.flushCopy(CopyDualImpl.java:28)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.updateStatusInternal(V3PGReplicationStream.java:193)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.timeUpdateStatus(V3PGReplicationStream.java:184)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.readInternal(V3PGReplicationStream.java:126)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.replication.V3PGReplicationStream.readPending(V3PGReplicationStream.java:80)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.connection.PostgresReplicationConnection$1.readPending(PostgresReplicationConnection.java:473)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.processMessages(PostgresStreamingChangeEventSource.java:188)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at io.debezium.connector.postgresql.PostgresStreamingChangeEventSource.execute(PostgresStreamingChangeEventSource.java:150)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	... 8 more
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 Caused by: java.net.SocketException: Connection or outbound has closed
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/sun.security.ssl.SSLSocketImpl$AppOutputStream.write(SSLSocketImpl.java:1190)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:81)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at java.base/java.io.BufferedOutputStream.flush(BufferedOutputStream.java:142)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.PGStream.flush(PGStream.java:592)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	at org.postgresql.core.v3.QueryExecutorImpl.flushCopy(QueryExecutorImpl.java:1078)
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	... 16 more
2021-09-21T22:02:05.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:05,522 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:07.028000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:07,027 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:07.522000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:07,522 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:07.615000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:07,615 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:02:07.615000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:07,615 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:02:07.616000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:07,616 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:02:09.028000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,028 WARN   ||  Value 'exported' of 'snapshot.mode' option is deprecated, use 'initial' instead   [io.debezium.connector.postgresql.PostgresConnectorConfig]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,028 INFO   ||  Starting PostgresConnectorTask with configuration:   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     connector.class = io.debezium.connector.postgresql.PostgresConnector   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     publication.autocreate.mode = filtered   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     database.dbname = hiring   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     database.user = app_debezium   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     slot.name = debezium_connect_user   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     acks = 2   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     publication.name = debezium_pub   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     database.server.name = prod   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     schema.include.list = user   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     heartbeat.interval.ms = 300000   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     database.port = 5432   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     plugin.name = pgoutput   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     schema.refresh.mode = columns_diff_exclude_unchanged_toast   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     database.sslmode = require   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     heartbeat.action.query = CREATE TABLE IF NOT EXISTS heartbeat (id SERIAL PRIMARY KEY, ts TIMESTAMP WITH TIME ZONE); INSERT INTO heartbeat (id, ts) VALUES (1, NOW()) ON CONFLICT(id) DO UPDATE SET ts=EXCLUDED.ts;   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     task.class = io.debezium.connector.postgresql.PostgresConnectorTask   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     table.exclude.list = user.session,user.user_reference,user.source   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     database.hostname = redacted.redacted.us-east-1.rds.amazonaws.com   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     database.password = ********   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     name = user   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.031000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,029 INFO   ||     snapshot.mode = exported   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:09.523000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:09,522 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:11.523000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:11,523 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:13.523000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:13,523 INFO   ||  Awaiting end of restart backoff period after a retriable error   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.523000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,523 WARN   ||  Value 'exported' of 'snapshot.mode' option is deprecated, use 'initial' instead   [io.debezium.connector.postgresql.PostgresConnectorConfig]
2021-09-21T22:02:15.524000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||  Starting PostgresConnectorTask with configuration:   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     connector.class = io.debezium.connector.postgresql.PostgresConnector   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     publication.autocreate.mode = filtered   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     database.dbname = hiring   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     database.user = app_debezium   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     slot.name = debezium_connect_jax   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     acks = 2   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     publication.name = debezium_pub   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     database.server.name = prod   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     schema.include.list = jax   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     heartbeat.interval.ms = 300000   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     snapshot.delay.ms = 60000   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     database.port = 5432   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     plugin.name = pgoutput   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     schema.refresh.mode = columns_diff_exclude_unchanged_toast   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     database.sslmode = require   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     slot.retry.delay.ms = 60000   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     heartbeat.action.query = CREATE TABLE IF NOT EXISTS heartbeat (id SERIAL PRIMARY KEY, ts TIMESTAMP WITH TIME ZONE); INSERT INTO heartbeat (id, ts) VALUES (1, NOW()) ON CONFLICT(id) DO UPDATE SET ts=EXCLUDED.ts;   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     task.class = io.debezium.connector.postgresql.PostgresConnectorTask   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     table.exclude.list = jax.user_request_log,jax.job_lookup_tier,jax.company_reference,jax.contact_reference,jax.application_reference,jax.job_reference,jax.user_reference,jax.job_lookup_reference,jax.application_action_reference,jax.email_reference,jax.interview_reference,jax.submission_reference,jax.call_log,jax.job_lookup   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     database.hostname = redacted.redacted.us-east-1.rds.amazonaws.com   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     database.password = ********   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     name = jax   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,524 INFO   ||     snapshot.mode = exported   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.609000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,609 INFO   ||  Found previous offset after restart PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prod'db='hiring', lsn=LSN{1269/13B41860}, txId=778404958, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@6ee07735, timestamp=2021-07-17T07:25:21.509763Z, snapshot=FALSE], partition={server=prod}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{1269/13B41860}, lastCommitLsn=LSN{1269/13B41860}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,613 INFO   Postgres|prod|postgres-connector-task  user 'app_debezium' connected to database 'hiring' on PostgreSQL 12.7 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 4.8.5 20150623 (Red Hat 4.8.5-11), 64-bit with roles:
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'rds_replication' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'rds_password' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'rds_superuser' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'app_debezium' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.614000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]   [io.debezium.connector.postgresql.PostgresConnectorTask]
2021-09-21T22:02:15.616000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,616 INFO   Postgres|prod|postgres-connector-task  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{1267/2C2362C8}, catalogXmin=777896357]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2021-09-21T22:02:15.616000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,616 INFO   Postgres|prod|postgres-connector-task  Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prod'db='hiring', lsn=LSN{1269/13B41860}, txId=778404958, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@6ee07735, timestamp=2021-07-17T07:25:21.509763Z, snapshot=FALSE], partition={server=prod}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{1269/13B41860}, lastCommitLsn=LSN{1269/13B41860}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]   [io.debezium.connector.postgresql.PostgresConnectorTask]
2021-09-21T22:02:15.616000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,616 INFO   Postgres|prod|postgres-connector-task  Previous snapshot has completed successfully, streaming logical changes from last known position   [io.debezium.connector.postgresql.snapshot.InitialSnapshotter]
2021-09-21T22:02:15.645000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,644 INFO   Postgres|prod|postgres-connector-task  Requested thread factory for connector PostgresConnector, id = prod named = change-event-source-coordinator   [io.debezium.util.Threads]
2021-09-21T22:02:15.645000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,645 INFO   Postgres|prod|postgres-connector-task  Creating thread debezium-postgresconnector-prod-change-event-source-coordinator   [io.debezium.util.Threads]
2021-09-21T22:02:15.645000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,645 INFO   Postgres|prod|snapshot  Metrics registered   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|snapshot  Context created   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|snapshot  Previous snapshot has completed successfully, streaming logical changes from last known position   [io.debezium.connector.postgresql.snapshot.InitialSnapshotter]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|snapshot  According to the connector configuration no snapshot will be executed   [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|snapshot  Snapshot ended with SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prod'db='hiring', lsn=LSN{1269/13B41860}, txId=778404958, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@6ee07735, timestamp=2021-07-17T07:25:21.509763Z, snapshot=FALSE], partition={server=prod}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{1269/13B41860}, lastCommitLsn=LSN{1269/13B41860}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]]   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|streaming  Connected metrics set to 'true'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|streaming  Starting streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|streaming  No incremental snapshot in progress, no action needed on start   [io.debezium.pipeline.source.snapshot.incremental.SignalBasedIncrementalSnapshotChangeEventSource]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|streaming  Retrieved latest position from stored offset 'LSN{1269/13B41860}'   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2021-09-21T22:02:15.646000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|streaming  Looking for WAL restart position for last commit LSN 'LSN{1269/13B41860}' and last change LSN 'LSN{1269/13B41860}'   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2021-09-21T22:02:15.647000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,646 INFO   Postgres|prod|streaming  Initializing PgOutput logical decoder publication   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2021-09-21T22:02:15.704000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,704 INFO   ||  Found previous offset after restart PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prod'db='hiring', lsn=LSN{13A4/89C06A18}, txId=856772708, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@770fec31, timestamp=2021-09-11T07:18:20.746872Z, snapshot=FALSE], partition={server=prod}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{13A4/89C06A18}, lastCommitLsn=LSN{13A4/89C06A18}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]   [io.debezium.connector.common.BaseSourceTask]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,711 INFO   Postgres|prod|postgres-connector-task  user 'app_debezium' connected to database 'hiring' on PostgreSQL 12.7 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 4.8.5 20150623 (Red Hat 4.8.5-11), 64-bit with roles:
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'rds_replication' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'rds_password' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'rds_superuser' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'app_debezium' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: true]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]
2021-09-21T22:02:15.711000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 	role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false]   [io.debezium.connector.postgresql.PostgresConnectorTask]
2021-09-21T22:02:15.712000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,712 INFO   Postgres|prod|postgres-connector-task  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{13A2/C1884960}, catalogXmin=855554967]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2021-09-21T22:02:15.712000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,712 INFO   Postgres|prod|postgres-connector-task  Found previous offset PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prod'db='hiring', lsn=LSN{13A4/89C06A18}, txId=856772708, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@770fec31, timestamp=2021-09-11T07:18:20.746872Z, snapshot=FALSE], partition={server=prod}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{13A4/89C06A18}, lastCommitLsn=LSN{13A4/89C06A18}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]   [io.debezium.connector.postgresql.PostgresConnectorTask]
2021-09-21T22:02:15.712000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,712 INFO   Postgres|prod|postgres-connector-task  Previous snapshot has completed successfully, streaming logical changes from last known position   [io.debezium.connector.postgresql.snapshot.InitialSnapshotter]
2021-09-21T22:02:15.736000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,736 INFO   Postgres|prod|postgres-connector-task  Requested thread factory for connector PostgresConnector, id = prod named = change-event-source-coordinator   [io.debezium.util.Threads]
2021-09-21T22:02:15.737000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,737 INFO   Postgres|prod|postgres-connector-task  Creating thread debezium-postgresconnector-prod-change-event-source-coordinator   [io.debezium.util.Threads]
2021-09-21T22:02:15.744000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,744 WARN   Postgres|prod|snapshot  Unable to register the MBean 'debezium.postgres:type=connector-metrics,context=snapshot,server=prod': debezium.postgres:type=connector-metrics,context=snapshot,server=prod   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.745000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,745 WARN   Postgres|prod|snapshot  Unable to register the MBean 'debezium.postgres:type=connector-metrics,context=streaming,server=prod': debezium.postgres:type=connector-metrics,context=streaming,server=prod   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.745000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,745 INFO   Postgres|prod|snapshot  Metrics registered   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.745000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,745 INFO   Postgres|prod|snapshot  Context created   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.745000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,745 INFO   Postgres|prod|snapshot  Previous snapshot has completed successfully, streaming logical changes from last known position   [io.debezium.connector.postgresql.snapshot.InitialSnapshotter]
2021-09-21T22:02:15.745000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,745 INFO   Postgres|prod|snapshot  According to the connector configuration no snapshot will be executed   [io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource]
2021-09-21T22:02:15.745000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,745 INFO   Postgres|prod|snapshot  Snapshot ended with SnapshotResult [status=SKIPPED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prod'db='hiring', lsn=LSN{13A4/89C06A18}, txId=856772708, sequence=[Lio.debezium.connector.postgresql.connection.Lsn;@770fec31, timestamp=2021-09-11T07:18:20.746872Z, snapshot=FALSE], partition={server=prod}, lastSnapshotRecord=false, lastCompletelyProcessedLsn=LSN{13A4/89C06A18}, lastCommitLsn=LSN{13A4/89C06A18}, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]]   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.802000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,802 INFO   Postgres|prod|streaming  Connected metrics set to 'true'   [io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics]
2021-09-21T22:02:15.802000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,802 INFO   Postgres|prod|streaming  Starting streaming   [io.debezium.pipeline.ChangeEventSourceCoordinator]
2021-09-21T22:02:15.802000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,802 INFO   Postgres|prod|streaming  No incremental snapshot in progress, no action needed on start   [io.debezium.pipeline.source.snapshot.incremental.SignalBasedIncrementalSnapshotChangeEventSource]
2021-09-21T22:02:15.802000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,802 INFO   Postgres|prod|streaming  Retrieved latest position from stored offset 'LSN{13A4/89C06A18}'   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2021-09-21T22:02:15.802000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,802 INFO   Postgres|prod|streaming  Looking for WAL restart position for last commit LSN 'LSN{13A4/89C06A18}' and last change LSN 'LSN{13A4/89C06A18}'   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2021-09-21T22:02:15.802000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,802 INFO   Postgres|prod|streaming  Initializing PgOutput logical decoder publication   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2021-09-21T22:02:15.834000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,834 INFO   Postgres|prod|streaming  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{1267/2C2362C8}, catalogXmin=777896357]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2021-09-21T22:02:15.842000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,842 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:02:15.922000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,922 INFO   Postgres|prod|streaming  Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{13A2/C1884960}, catalogXmin=855554967]   [io.debezium.connector.postgresql.connection.PostgresConnection]
2021-09-21T22:02:15.928000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:15,928 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:02:20.061000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,061 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.social' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.062000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,062 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.education' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.062000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,062 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.degree' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.063000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,063 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.user' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.064000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,064 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.user_meta' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.065000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,065 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.resume' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.065000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,065 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.company' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.067000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,067 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.resume_reference' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.068000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,068 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.social_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.069000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,069 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.notification_setting' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.069000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,069 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.title' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.069000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,069 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.review' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.070000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,070 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.phone' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.070000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,070 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.work_authorization' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.070000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,070 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.resume_revision' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.070000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,070 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.timezone' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.072000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,072 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.experience' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.072000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,072 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.lead' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.072000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,072 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.study_field' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.073000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,073 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.notification_category' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.074000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,074 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.school' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.074000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,074 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'user.salary_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.126000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,126 INFO   Postgres|prod|streaming  Searching for WAL resume position   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2021-09-21T22:02:20.755000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,755 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.756000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,756 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.assessment_question' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.756000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,756 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_attachment_open' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.757000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,757 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.758000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,758 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.interview' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.758000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,758 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.jobot_scout_job' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.759000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,759 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_title' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.759000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,759 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.platform' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.761000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,761 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_industry' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.761000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,761 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_phone' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.761000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,761 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_assessment_question' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.762000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,762 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.notification' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.762000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,762 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.jobot_scout' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.763000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,763 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.industry_reference' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.764000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,764 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.placement_video' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.765000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,765 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.interview_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.765000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,765 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.jobot_scout_contact' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.765000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,765 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_position_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.765000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,765 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_tag' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.765000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,765 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_billing' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.766000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,766 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_template_field_value' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.766000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,766 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_location' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.766000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,766 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_preferred_company' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.766000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,766 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.submission' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.767000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,767 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.rewards_catalog' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.767000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,767 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_ad' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.767000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,767 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_click' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.767000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,767 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.botcoin_ledger' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.768000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,768 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_meta' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.768000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,768 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.permission' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.768000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,768 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.title_group' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.768000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,768 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_industry_category' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.769000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,769 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_transfer' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.769000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,769 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.permission_scope' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.769000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,769 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.agreement_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.769000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,769 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.user_goal' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.769000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,769 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_blocked' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.770000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,770 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_description' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.770000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,770 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.770000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,770 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.smtp_api_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.770000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,770 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.title_option' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.770000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,770 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_job_title' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.771000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,771 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.promotion_parameters' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.771000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,771 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_job_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.771000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,771 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.user_profile' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.772000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,772 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_contact' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.772000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,772 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.sms_log' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.772000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,772 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.parsed_resume' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.772000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,772 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.industry_category_reference' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.773000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,772 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.application_action' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.773000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,773 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.user' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.774000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,774 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.application_status' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.774000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,774 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_resume' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.774000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,774 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.industry' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.775000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,775 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_open' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.776000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,776 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.notification_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.776000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,776 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_assessment_skill' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.776000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,776 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.placement' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.777000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,777 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_social' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.777000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,777 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_education' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.777000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,777 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.contact' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.778000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,778 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_user' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.778000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,778 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_type' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.778000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,778 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.goal_billing' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.778000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,778 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_template' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.779000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,779 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_request' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.779000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,779 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.team_user' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.779000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,779 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_description_override' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.779000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,779 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_recipient' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.780000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,780 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_agreement' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.780000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,780 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_social' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.780000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,780 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_template_part' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.780000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,780 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_experience_level' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.781000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,781 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_assessment' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.781000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,781 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.company_user' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.782000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,782 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.placement_reference' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.782000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,782 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.smtp_api' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.782000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,782 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.platform_apply' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.782000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,782 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.contact_social' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.783000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,782 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_template' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.783000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,783 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.tag' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.783000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,783 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.application_assessment' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.783000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,783 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_experience' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.783000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,783 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.user_folder' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.784000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,784 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.industry_category' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.784000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,784 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_intel' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.784000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,784 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_attachment' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.784000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,784 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.contact_phone' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.785000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,784 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.email_template_field' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.785000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,785 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_description_part' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.785000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,785 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.application' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.786000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,786 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.rules_of_engagement' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.786000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,786 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.placement_contact' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.786000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,786 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.role' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.787000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,786 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_skill' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.787000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,787 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.application_bugfix' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.787000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,787 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.assessment_skill' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.787000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,787 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_type_limit' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.788000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,788 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.goal_quarter' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.788000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,788 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.intel_question' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.788000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,788 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.placement_video_seen' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.788000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,788 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_type_internal' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.789000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,789 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_saved_search' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.789000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,789 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.team' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.789000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,789 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_claim' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.790000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,790 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.candidate_folder' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.790000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,790 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.791000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,791 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.job_status' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.791000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,791 INFO   Postgres|prod|streaming  REPLICA IDENTITY for 'jax.smtp' is 'DEFAULT'; UPDATE and DELETE events will contain previous values only for PK columns   [io.debezium.connector.postgresql.PostgresSchema]
2021-09-21T22:02:20.885000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:02:20,884 INFO   Postgres|prod|streaming  Searching for WAL resume position   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2021-09-21T22:03:04.764000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:03:04,764 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:03:04.764000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:03:04,764 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:03:07.616000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:03:07,616 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:03:07.616000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:03:07,616 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:04:01.477000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:01,477 INFO   Postgres|prod|streaming  First LSN 'LSN{13A4/89C069E0}' received   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2021-09-21T22:04:01.558000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:01,558 INFO   Postgres|prod|streaming  LSN after last stored change LSN 'LSN{13A4/89C06AD0}' received   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2021-09-21T22:04:01.558000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:01,558 INFO   Postgres|prod|streaming  WAL resume position 'LSN{13A4/89C06AD0}' discovered   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2021-09-21T22:04:01.559000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:01,559 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:04:01.570000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:01,570 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:04:01.597000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:01,597 INFO   Postgres|prod|streaming  Initializing PgOutput logical decoder publication   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2021-09-21T22:04:01.648000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:01,648 INFO   Postgres|prod|streaming  Processing messages   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2021-09-21T22:04:02.660000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:02,660 INFO   Postgres|prod|streaming  Streaming requested from LSN LSN{13A4/89C06A18}, received LSN LSN{13A4/89C069E0} identified as already processed   [io.debezium.connector.postgresql.connection.AbstractMessageDecoder]
2021-09-21T22:04:02.660000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:02,660 INFO   Postgres|prod|streaming  Streaming requested from LSN LSN{13A4/89C06A18}, received LSN LSN{0/0} identified as already processed   [io.debezium.connector.postgresql.connection.AbstractMessageDecoder]
2021-09-21T22:04:02.761000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:02,761 INFO   Postgres|prod|streaming  Streaming requested from LSN LSN{13A4/89C06A18}, received LSN LSN{13A4/89C06A18} identified as already processed   [io.debezium.connector.postgresql.connection.AbstractMessageDecoder]
2021-09-21T22:04:02.761000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:02,761 INFO   Postgres|prod|streaming  Message with LSN 'LSN{13A4/89C06AD0}' arrived, switching off the filtering   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2021-09-21T22:04:04.765000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:04,765 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:04:04.765000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:04,765 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:04:07.617000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:07,617 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:04:07.617000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:07,617 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:04:07.618000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:07,617 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 0 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:04:56.446000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:56,446 INFO   Postgres|prod|streaming  First LSN 'LSN{1269/13B41828}' received   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2021-09-21T22:04:56.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:56,525 INFO   Postgres|prod|streaming  LSN after last stored change LSN 'LSN{1269/13B41958}' received   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2021-09-21T22:04:56.525000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:56,525 INFO   Postgres|prod|streaming  WAL resume position 'LSN{1269/13B41958}' discovered   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2021-09-21T22:04:56.532000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:56,532 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:04:56.534000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:56,534 INFO   Postgres|prod|streaming  Connection gracefully closed   [io.debezium.jdbc.JdbcConnection]
2021-09-21T22:04:56.553000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:56,553 INFO   Postgres|prod|streaming  Initializing PgOutput logical decoder publication   [io.debezium.connector.postgresql.connection.PostgresReplicationConnection]
2021-09-21T22:04:56.845000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:04:56,845 INFO   Postgres|prod|streaming  Processing messages   [io.debezium.connector.postgresql.PostgresStreamingChangeEventSource]
2021-09-21T22:05:04.768000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:04,768 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:05:04.768000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:04,768 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:05:07.618000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:07,618 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:05:07.618000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:07,618 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:05:07.619000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:07,619 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:05:09.988000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:09,988 INFO   Postgres|prod|streaming  Streaming requested from LSN LSN{1269/13B41860}, received LSN LSN{1269/13B41828} identified as already processed   [io.debezium.connector.postgresql.connection.AbstractMessageDecoder]
2021-09-21T22:05:09.988000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:09,988 INFO   Postgres|prod|streaming  Streaming requested from LSN LSN{1269/13B41860}, received LSN LSN{0/0} identified as already processed   [io.debezium.connector.postgresql.connection.AbstractMessageDecoder]
2021-09-21T22:05:10.103000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:10,103 INFO   Postgres|prod|streaming  Streaming requested from LSN LSN{1269/13B41860}, received LSN LSN{1269/13B41860} identified as already processed   [io.debezium.connector.postgresql.connection.AbstractMessageDecoder]
2021-09-21T22:05:10.103000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:05:10,103 INFO   Postgres|prod|streaming  Message with LSN 'LSN{1269/13B41958}' arrived, switching off the filtering   [io.debezium.connector.postgresql.connection.WalPositionLocator]
2021-09-21T22:06:04.799000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:06:04,799 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:06:04.800000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:06:04,800 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:06:04.802000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:06:04,802 INFO   ||  WorkerSourceTask{id=user-0} Finished commitOffsets successfully in 2 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:06:07.619000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:06:07,619 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:06:07.620000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:06:07,620 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:06:07.620000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:06:07,620 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 0 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:06:47.440000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:06:47,440 WARN   Postgres|prod|streaming  Primary keys are not defined for table 'placement_video_seen', defaulting to unique indices   [io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder]
2021-09-21T22:07:04.803000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:07:04,803 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:07:04.803000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:07:04,803 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:07:04.804000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:07:04,804 INFO   ||  WorkerSourceTask{id=user-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:07:07.621000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:07:07,621 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:07:07.621000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:07:07,621 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:07:07.622000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:07:07,622 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:07:26.322000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:07:26,322 WARN   Postgres|prod|streaming  Primary keys are not defined for table 'placement_video_seen', defaulting to unique indices   [io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder]
2021-09-21T22:08:04.804000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:08:04,804 INFO   ||  WorkerSourceTask{id=user-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:08:04.805000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:08:04,804 INFO   ||  WorkerSourceTask{id=user-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:08:04.806000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:08:04,806 INFO   ||  WorkerSourceTask{id=user-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:08:07.623000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:08:07,623 INFO   ||  WorkerSourceTask{id=jax-0} Committing offsets   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:08:07.623000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:08:07,623 INFO   ||  WorkerSourceTask{id=jax-0} flushing 0 outstanding messages for offset commit   [org.apache.kafka.connect.runtime.WorkerSourceTask]
2021-09-21T22:08:07.624000+00:00 ecs/debezium-connect/f93f86e9a7ea41939258ac6d4af5ae58 2021-09-21 22:08:07,624 INFO   ||  WorkerSourceTask{id=jax-0} Finished commitOffsets successfully in 1 ms   [org.apache.kafka.connect.runtime.WorkerSourceTask]