C:\some\path\.jdks\corretto-17.0.7\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA Community Edition 2025.2.1\lib\idea_rt.jar=60856" -Dfile.encoding=UTF-8 @C:\some\path\AppData\Local\Temp\idea_arg_file545812377 com.mycompany.replication.ReplicatorApp Standard Commons Logging discovery in action with spring-jcl: please remove commons-logging.jar from classpath in order to avoid potential conflicts Standard Commons Logging discovery in action with spring-jcl: please remove commons-logging.jar from classpath in order to avoid potential conflicts 2025-09-15 17:17:23,626 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - Starting JdbcSinkConnectorConfig with configuration: 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - connector.class = io.debezium.connector.jdbc.JdbcSinkConnector 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - connection.password = ******** 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - primary.key.mode = record_key 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - converter.type = header 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - tasks.max = 1 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - topics = some.topic 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - connection.username = *** 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - internal.key.converter = org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - collection.name.format = ${source.schema}.${source.table} 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - offset.storage.file.filename = C:\some\path\Desktop/kafka/offsets-some.name.dat 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - delete.enabled = true 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - internal.value.converter = org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - name = some.name 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - auto.create = true 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - value.converter = org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - connection.url = jdbc:postgresql://localhost:5432/replication 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - insert.mode = upsert 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - key.converter = org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:23,632 INFO [main] io.debezium.connector.jdbc.JdbcSinkConnectorTask - schemas.enable = true 2025-09-15 17:17:23,857 INFO [main] io.debezium.connector.jdbc.dialect.DatabaseDialectResolver - Using dialect io.debezium.connector.jdbc.dialect.postgres.PostgresDatabaseDialect 2025-09-15 17:17:25,552 INFO [main] io.debezium.embedded.EmbeddedWorkerConfig - EmbeddedWorkerConfig values: access.control.allow.methods = access.control.allow.origin = admin.listeners = null auto.include.jmx.reporter = true bootstrap.servers = [localhost:9092] client.dns.lookup = use_all_dns_ips config.providers = [] connector.client.config.override.policy = All header.converter = class org.apache.kafka.connect.storage.SimpleHeaderConverter key.converter = class org.apache.kafka.connect.json.JsonConverter listeners = [http://:8083] metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 offset.flush.interval.ms = 0 offset.flush.timeout.ms = 5000 offset.storage.file.filename = C:\some\path\Desktop/kafka/offsets-lrx_sc_tobjectstorage_tlinkstorage.dat offset.storage.partitions = null offset.storage.replication.factor = null offset.storage.topic = plugin.discovery = hybrid_warn plugin.path = null response.http.headers.config = rest.advertised.host.name = null rest.advertised.listener = null rest.advertised.port = null rest.extension.classes = [] ssl.cipher.suites = null ssl.client.auth = none ssl.enabled.protocols = [TLSv1.2, TLSv1.3] ssl.endpoint.identification.algorithm = https ssl.engine.factory.class = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.certificate.chain = null ssl.keystore.key = null ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLSv1.3 ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.certificates = null ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS task.shutdown.graceful.timeout.ms = 5000 topic.creation.enable = true topic.tracking.allow.reset = true topic.tracking.enable = true value.converter = class org.apache.kafka.connect.json.JsonConverter 2025-09-15 17:17:25,579 INFO [pool-2-thread-1] io.debezium.config.CommonConnectorConfig - Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker 2025-09-15 17:17:25,651 INFO [pool-2-thread-1] io.debezium.connector.postgresql.PostgresConnector - Successfully tested connection for jdbc:postgresql://localhost:5432/my_db with user '***' 2025-09-15 17:17:25,659 INFO [pool-3-thread-1] io.debezium.jdbc.JdbcConnection - Connection gracefully closed 2025-09-15 17:17:25,676 INFO [pool-2-thread-1] io.debezium.connector.common.BaseSourceTask - Starting PostgresConnectorTask with configuration: connector.class = io.debezium.connector.postgresql.PostgresConnector slot.name = rs_lrx_sc_tobjectstorage_tlinkstorage publication.name = pub_lrx_sc_tobjectstorage_tlinkstorage provide.transaction.metadata = true tombstones.on.delete = false topic.prefix = prefix_lrx_sc_tobjectstorage_tlinkstorage offset.storage.file.filename = C:\some\path\Desktop/kafka/offsets-lrx_sc_tobjectstorage_tlinkstorage.dat signal.data.collection = public.debezium_signal copy.existing = false errors.retry.delay.initial.ms = 300 value.converter = org.apache.kafka.connect.json.JsonConverter key.converter = org.apache.kafka.connect.json.JsonConverter publication.autocreate.mode = all_tables database.user = *** database.dbname = my_db offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore offset.flush.timeout.ms = 5000 errors.retry.delay.max.ms = 10000 database.port = 5432 plugin.name = pgoutput offset.flush.interval.ms = 0 errors.max.retries = -1 database.hostname = localhost database.password = ******** name = lrx_sc_tobjectstorage_tlinkstorage table.include.list = public.tobjectstorage,public.tlinkstorage snapshot.mode = initial 2025-09-15 17:17:25,676 INFO [pool-2-thread-1] io.debezium.config.CommonConnectorConfig - Loading the custom source info struct maker plugin: io.debezium.connector.postgresql.PostgresSourceInfoStructMaker 2025-09-15 17:17:25,677 INFO [pool-2-thread-1] io.debezium.config.CommonConnectorConfig - Loading the custom topic naming strategy plugin: io.debezium.schema.SchemaTopicNamingStrategy 2025-09-15 17:17:25,701 INFO [pool-4-thread-1] io.debezium.jdbc.JdbcConnection - Connection gracefully closed 2025-09-15 17:17:25,741 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13523, name:_pg_user_mappings] is already mapped 2025-09-15 17:17:25,741 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13197, name:cardinal_number] is already mapped 2025-09-15 17:17:25,741 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13200, name:character_data] is already mapped 2025-09-15 17:17:25,741 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13202, name:sql_identifier] is already mapped 2025-09-15 17:17:25,741 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13208, name:time_stamp] is already mapped 2025-09-15 17:17:25,741 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13210, name:yes_or_no] is already mapped 2025-09-15 17:17:25,761 INFO [pool-2-thread-1] io.debezium.connector.common.BaseSourceTask - No previous offsets found 2025-09-15 17:17:25,794 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13523, name:_pg_user_mappings] is already mapped 2025-09-15 17:17:25,794 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13197, name:cardinal_number] is already mapped 2025-09-15 17:17:25,794 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13200, name:character_data] is already mapped 2025-09-15 17:17:25,794 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13202, name:sql_identifier] is already mapped 2025-09-15 17:17:25,794 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13208, name:time_stamp] is already mapped 2025-09-15 17:17:25,794 WARN [pool-2-thread-1] io.debezium.connector.postgresql.TypeRegistry - Type [oid:13210, name:yes_or_no] is already mapped 2025-09-15 17:17:25,806 INFO [pool-2-thread-1] io.debezium.connector.common.BaseSourceTask - Connector started for the first time. 2025-09-15 17:17:25,807 INFO [pool-2-thread-1] io.debezium.connector.postgresql.PostgresConnectorTask - No previous offset found 2025-09-15 17:17:25,808 INFO [pool-2-thread-1] io.debezium.connector.postgresql.PostgresConnectorTask - user '***' connected to database 'my_db' on PostgreSQL 15.2, compiled by Visual C++ build 1914, 64-bit with roles: role 'pg_read_all_settings' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_database_owner' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_checkpoint' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_write_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'apacs' [superuser: true, replication: false, inherit: true, create role: true, create db: true, can log in: true] role 'pg_read_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_write_all_data' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'apc' [superuser: true, replication: false, inherit: true, create role: true, create db: true, can log in: true] role 'pg_monitor' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_server_files' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_execute_server_program' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_read_all_stats' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'pg_signal_backend' [superuser: false, replication: false, inherit: true, create role: false, create db: false, can log in: false] role 'postgres' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] role '***' [superuser: true, replication: true, inherit: true, create role: true, create db: true, can log in: true] 2025-09-15 17:17:25,810 INFO [pool-2-thread-1] io.debezium.connector.postgresql.connection.PostgresConnection - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{32/AE2B9DD0}, catalogXmin=13857933] 2025-09-15 17:17:25,821 INFO [pool-2-thread-1] io.debezium.util.Threads - Requested thread factory for component PostgresConnector, id = prefix_lrx_sc_tobjectstorage_tlinkstorage named = SignalProcessor 2025-09-15 17:17:25,833 INFO [pool-2-thread-1] io.debezium.util.Threads - Requested thread factory for component PostgresConnector, id = prefix_lrx_sc_tobjectstorage_tlinkstorage named = change-event-source-coordinator 2025-09-15 17:17:25,833 INFO [pool-2-thread-1] io.debezium.util.Threads - Requested thread factory for component PostgresConnector, id = prefix_lrx_sc_tobjectstorage_tlinkstorage named = blocking-snapshot 2025-09-15 17:17:25,837 INFO [pool-2-thread-1] io.debezium.util.Threads - Creating thread debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator 2025-09-15 17:17:25,839 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Metrics registered 2025-09-15 17:17:25,840 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Context created 2025-09-15 17:17:25,846 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource - According to the connector configuration data will be snapshotted 2025-09-15 17:17:25,849 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 1 - Preparing 2025-09-15 17:17:25,849 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 2 - Determining captured tables 2025-09-15 17:17:25,851 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table my_db.public.tlinkstorage to the list of capture schema tables 2025-09-15 17:17:25,852 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table my_db.public.tobjectstorage to the list of capture schema tables 2025-09-15 17:17:25,853 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Created connection pool with 1 threads 2025-09-15 17:17:25,853 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 3 - Locking captured tables [my_db.public.tobjectstorage, my_db.public.tlinkstorage, my_db.public.debezium_signal] 2025-09-15 17:17:25,854 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 4 - Determining snapshot offset 2025-09-15 17:17:25,858 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresOffsetContext - Creating initial offset context 2025-09-15 17:17:25,863 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresOffsetContext - Read xlogStart at 'LSN{32/AE2BAB68}' from transaction '13857952' 2025-09-15 17:17:25,869 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource - Read xlogStart at 'LSN{32/AE2BAB68}' from transaction '13857952' 2025-09-15 17:17:25,870 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 5 - Reading structure of captured tables 2025-09-15 17:17:25,870 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSnapshotChangeEventSource - Reading structure of schema 'public' of catalog 'my_db' 2025-09-15 17:17:25,953 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 6 - Persisting schema history 2025-09-15 17:17:25,954 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 7 - Snapshotting data 2025-09-15 17:17:25,956 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - Creating snapshot worker pool with 1 worker thread(s) 2025-09-15 17:17:25,960 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - For table 'my_db.public.tobjectstorage' using select statement: 'SELECT "fid", "fname", "ftypename", "flabel", "fdata" FROM "my_db"."public"."tobjectstorage"' 2025-09-15 17:17:25,961 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - For table 'my_db.public.tlinkstorage' using select statement: 'SELECT "fid", "fname", "ftype", "fdata", "fsrcobject", "fdestobject" FROM "my_db"."public"."tlinkstorage"' 2025-09-15 17:17:25,961 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.relational.RelationalSnapshotChangeEventSource - For table 'my_db.public.debezium_signal' using select statement: 'SELECT "id", "type", "data" FROM "my_db"."public"."debezium_signal"' 2025-09-15 17:17:25,964 INFO [pool-5-thread-1] io.debezium.relational.RelationalSnapshotChangeEventSource - Exporting data from table 'my_db.public.tobjectstorage' (1 of 3 tables) 2025-09-15 17:17:26,143 INFO [pool-5-thread-1] io.debezium.relational.RelationalSnapshotChangeEventSource - Finished exporting 492 records for table 'my_db.public.tobjectstorage' (1 of 3 tables); total duration '00:00:00.179' 2025-09-15 17:17:26,145 INFO [pool-5-thread-1] io.debezium.relational.RelationalSnapshotChangeEventSource - Exporting data from table 'my_db.public.tlinkstorage' (2 of 3 tables) 2025-09-15 17:17:26,168 INFO [pool-5-thread-1] io.debezium.relational.RelationalSnapshotChangeEventSource - Finished exporting 509 records for table 'my_db.public.tlinkstorage' (2 of 3 tables); total duration '00:00:00.023' 2025-09-15 17:17:26,169 INFO [pool-5-thread-1] io.debezium.relational.RelationalSnapshotChangeEventSource - Exporting data from table 'my_db.public.debezium_signal' (3 of 3 tables) 2025-09-15 17:17:26,173 INFO [pool-5-thread-1] io.debezium.relational.RelationalSnapshotChangeEventSource - Finished exporting 88 records for table 'my_db.public.debezium_signal' (3 of 3 tables); total duration '00:00:00.004' 2025-09-15 17:17:26,177 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.source.AbstractSnapshotChangeEventSource - Snapshot - Final stage 2025-09-15 17:17:26,177 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.source.AbstractSnapshotChangeEventSource - Snapshot completed 2025-09-15 17:17:26,177 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Snapshot ended with SnapshotResult [status=COMPLETED, offset=PostgresOffsetContext [sourceInfoSchema=Schema{io.debezium.connector.postgresql.Source:STRUCT}, sourceInfo=source_info[server='prefix_lrx_sc_tobjectstorage_tlinkstorage'db='my_db', lsn=LSN{32/AE2BAB68}, txId=13857952, timestamp=2025-09-15T14:17:25.849943Z, snapshot=FALSE, schema=public, table=debezium_signal], lastSnapshotRecord=true, lastCompletelyProcessedLsn=null, lastCommitLsn=null, streamingStoppingLsn=null, transactionContext=TransactionContext [currentTransactionId=null, perTableEventCount={}, totalEventCount=0], incrementalSnapshotContext=IncrementalSnapshotContext [windowOpened=false, chunkEndPosition=null, dataCollectionsToSnapshot=[], lastEventKeySent=null, maximumKey=null]]] 2025-09-15 17:17:26,207 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Connected metrics set to 'true' 2025-09-15 17:17:26,225 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'my_db.public.debezium_signal' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns 2025-09-15 17:17:26,225 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'my_db.public.tlinkstorage' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns 2025-09-15 17:17:26,226 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresSchema - REPLICA IDENTITY for 'my_db.public.tobjectstorage' is 'FULL'; UPDATE AND DELETE events will contain the previous values of all the columns 2025-09-15 17:17:26,241 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource - No incremental snapshot in progress, no action needed on start 2025-09-15 17:17:26,258 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.signal.SignalProcessor - SignalProcessor started. Scheduling it every 5000ms 2025-09-15 17:17:26,260 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.util.Threads - Creating thread debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-SignalProcessor 2025-09-15 17:17:26,261 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.pipeline.ChangeEventSourceCoordinator - Starting streaming 2025-09-15 17:17:26,261 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Retrieved latest position from stored offset 'LSN{32/AE2BAB68}' 2025-09-15 17:17:26,263 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.connection.WalPositionLocator - Looking for WAL restart position for last commit LSN 'null' and last change LSN 'LSN{32/AE2BAB68}' 2025-09-15 17:17:26,263 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.connection.PostgresReplicationConnection - Initializing PgOutput logical decoder publication 2025-09-15 17:17:26,322 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.connection.PostgresConnection - Obtained valid replication slot ReplicationSlot [active=false, latestFlushedLsn=LSN{32/AE2B9DD0}, catalogXmin=13857933] 2025-09-15 17:17:26,323 INFO [pool-6-thread-1] io.debezium.jdbc.JdbcConnection - Connection gracefully closed 2025-09-15 17:17:26,377 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.util.Threads - Requested thread factory for component PostgresConnector, id = prefix_lrx_sc_tobjectstorage_tlinkstorage named = keep-alive 2025-09-15 17:17:26,379 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.util.Threads - Creating thread debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-keep-alive 2025-09-15 17:17:26,379 INFO [debezium-postgresconnector-prefix_lrx_sc_tobjectstorage_tlinkstorage-change-event-source-coordinator] io.debezium.connector.postgresql.PostgresStreamingChangeEventSource - Processing messages 2025-09-15 17:17:30,765 INFO [pool-2-thread-1] io.debezium.connector.common.BaseSourceTask - Found previous partition offset PostgresPartition [sourcePartition={server=prefix_lrx_sc_tobjectstorage_tlinkstorage}]: {lsn=217670462312, txId=13857952, ts_usec=1757945845849943}