at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:293)
	at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.init(AbstractIncrementalSnapshotChangeEventSource.java:242)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$initStreamEvents$1(ChangeEventSourceCoordinator.java:185)
	at java.base/java.util.Optional.ifPresent(Optional.java:183)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.initStreamEvents(ChangeEventSourceCoordinator.java:185)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:170)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:139)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:108)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)
Caused by: org.postgresql.util.PSQLException: An I/O error occurred while sending to the backend.
	at org.postgresql.core.v3.QueryExecutorImpl.fetch(QueryExecutorImpl.java:2566)
	at org.postgresql.jdbc.PgResultSet.next(PgResultSet.java:2098)
	at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.createDataEventsForTable(AbstractIncrementalSnapshotChangeEventSource.java:436)
	... 13 more
Caused by: java.io.EOFException
	at org.postgresql.core.PGStream.receive(PGStream.java:648)
	at org.postgresql.core.PGStream.receiveTupleV3(PGStream.java:606)
	at org.postgresql.core.v3.QueryExecutorImpl.processResults(QueryExecutorImpl.java:2332)
	at org.postgresql.core.v3.QueryExecutorImpl.fetch(QueryExecutorImpl.java:2561)
	... 15 more
[2022-09-19 14:01:52,659] INFO Connected metrics set to 'false' (io.debezium.pipeline.metrics.StreamingChangeEventSourceMetrics:70)
[2022-09-19 14:01:52,658] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965)
[2022-09-19 14:01:52,660] INFO [Producer clientId=connector-producer-om-s-connector-01-0] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1204)
[2022-09-19 14:01:52,660] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659)
[2022-09-19 14:01:52,660] INFO Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663)
[2022-09-19 14:01:52,660] INFO Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669)
[2022-09-19 14:01:52,661] INFO App info kafka.producer for connector-producer-om-s-connector-01-0 unregistered (org.apache.kafka.common.utils.AppInfoParser:83)
[2022-09-19 14:01:57,616] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:02:57,616] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:03:57,617] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:04:57,617] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:05:57,618] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:06:57,618] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:07:57,618] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:08:57,619] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:09:57,619] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:10:57,619] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:11:57,620] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:12:42,574] INFO Incremental snapshot in progress, loading of initial chunk completed (io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource:247)
[2022-09-19 14:12:42,574] INFO Starting streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:171)
[2022-09-19 14:12:42,574] INFO Retrieved latest position from stored offset 'LSN{10F2/B2C44F68}' (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource:127)
[2022-09-19 14:12:42,574] INFO Looking for WAL restart position for last commit LSN 'LSN{10F2/B2C44F68}' and last change LSN 'LSN{10F2/B2C44F68}' (io.debezium.connector.postgresql.connection.WalPositionLocator:40)
[2022-09-19 14:12:42,575] INFO Initializing PgOutput logical decoder publication (io.debezium.connector.postgresql.connection.PostgresReplicationConnection:134)
[2022-09-19 14:12:42,706] INFO Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{10F2/AF108A60}, catalogXmin=3786460707] (io.debezium.connector.postgresql.connection.PostgresConnection:244)
[2022-09-19 14:12:42,707] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965)
[2022-09-19 14:12:42,722] INFO Requested thread factory for connector PostgresConnector, id = om_s named = keep-alive (io.debezium.util.Threads:270)
[2022-09-19 14:12:42,722] INFO Creating thread debezium-postgresconnector-om_s-keep-alive (io.debezium.util.Threads:287)
[2022-09-19 14:12:42,773] INFO REPLICA IDENTITY for 'public.sales_order_item' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns (io.debezium.connector.postgresql.PostgresSchema:104)
[2022-09-19 14:12:42,774] INFO REPLICA IDENTITY for 'public.debezium_signal_1' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns (io.debezium.connector.postgresql.PostgresSchema:104)
[2022-09-19 14:12:42,806] INFO Searching for WAL resume position (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource:313)
[2022-09-19 14:12:57,620] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:13:05,580] INFO First LSN 'LSN{10F2/B2C44F68}' received (io.debezium.connector.postgresql.connection.WalPositionLocator:60)
[2022-09-19 14:13:05,647] INFO LSN after last stored change LSN 'LSN{10F2/B2C45040}' received (io.debezium.connector.postgresql.connection.WalPositionLocator:71)
[2022-09-19 14:13:05,647] INFO WAL resume position 'LSN{10F2/B2C45040}' discovered (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource:334)
[2022-09-19 14:13:05,648] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965)
[2022-09-19 14:13:05,650] INFO Connection gracefully closed (io.debezium.jdbc.JdbcConnection:965)
[2022-09-19 14:13:05,676] INFO Initializing PgOutput logical decoder publication (io.debezium.connector.postgresql.connection.PostgresReplicationConnection:134)
[2022-09-19 14:13:05,692] INFO Requested thread factory for connector PostgresConnector, id = om_s named = keep-alive (io.debezium.util.Threads:270)
[2022-09-19 14:13:05,692] INFO Creating thread debezium-postgresconnector-om_s-keep-alive (io.debezium.util.Threads:287)
[2022-09-19 14:13:05,692] INFO Processing messages (io.debezium.connector.postgresql.PostgresStreamingChangeEventSource:202)
[2022-09-19 14:13:06,044] INFO 1 records sent during previous 00:14:08.462, last recorded offset: {transaction_id=null, lsn_proc=18634567339880, lsn_commit=18634567339880, lsn=18634567339880, incremental_snapshot_maximum_key=aced0005757200135b4c6a6176612e6c616e672e4f626a6563743b90ce589f1073296c0200007870000000027372000e6a6176612e7574696c2e55554944bc9903f7986d852f0200024a000c6c65617374536967426974734a000b6d6f7374536967426974737870a25b7c8da884d768ffffffe3e3bd442674000b626f617264726964657273, txId=3786544991, incremental_snapshot_collections=public.sales_order_item, ts_usec=1663593975159811, incremental_snapshot_primary_key=aced000570} (io.debezium.connector.common.BaseSourceTask:182)
[2022-09-19 14:13:16,359] INFO Streaming requested from LSN LSN{10F2/B2C44F68}, received LSN LSN{10F2/B2C44F68} identified as already processed (io.debezium.connector.postgresql.connection.AbstractMessageDecoder:45)
[2022-09-19 14:13:16,359] INFO Streaming requested from LSN LSN{10F2/B2C44F68}, received LSN LSN{0/0} identified as already processed (io.debezium.connector.postgresql.connection.AbstractMessageDecoder:45)
[2022-09-19 14:13:16,417] INFO Streaming requested from LSN LSN{10F2/B2C44F68}, received LSN LSN{10F2/B2C44F68} identified as already processed (io.debezium.connector.postgresql.connection.AbstractMessageDecoder:45)
[2022-09-19 14:13:16,417] INFO Message with LSN 'LSN{10F2/B2C45040}' arrived, switching off the filtering (io.debezium.connector.postgresql.connection.WalPositionLocator:134)
[2022-09-19 14:13:16,424] WARN Primary keys are not defined for table 'debezium_heartbeat_table', defaulting to unique indices (io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder:299)
[2022-09-19 14:13:16,439] WARN Column 'text' optionality could not be determined, defaulting to true (io.debezium.connector.postgresql.connection.pgoutput.PgOutputMessageDecoder:316)
[2022-09-19 14:13:16,440] INFO Received request to open window with id = '3bb2bf9c-a81d-411e-90d5-ccbbc9fb08ac-open', expected = '2fa5095c-e165-423c-ac30-f189b535528f', request ignored (io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotContext:87)
[2022-09-19 14:13:29,657] INFO Received request to open window with id = 'cef40236-2fb9-41b2-b195-af3beef073fd-open', expected = '2fa5095c-e165-423c-ac30-f189b535528f', request ignored (io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotContext:87)
[2022-09-19 14:13:42,853] INFO Received request to open window with id = '75f252e1-e8d4-4d28-a68c-dc58189a3a4e-open', expected = '2fa5095c-e165-423c-ac30-f189b535528f', request ignored (io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotContext:87)
[2022-09-19 14:13:44,882] INFO Received request to close window with id = 'cef40236-2fb9-41b2-b195-af3beef073fd-close', expected = '2fa5095c-e165-423c-ac30-f189b535528f', request ignored (io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotContext:97)
[2022-09-19 14:13:57,620] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:14:57,626] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:15:14,240] INFO [Worker clientId=connect-1, groupId=order_management_connect_cluster_config] Connector om-s-connector-01 target state change (org.apache.kafka.connect.runtime.distributed.DistributedHerder:1577)
[2022-09-19 14:15:57,630] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:16:57,630] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:17:57,631] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:18:57,631] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:19:57,631] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:20:57,632] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:21:57,632] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)
[2022-09-19 14:22:57,633] INFO WorkerSourceTask{id=om-s-connector-01-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:510)